test_class.declarator: closed = false
test_class.original_string: boolean closed = false;
test_class.type: boolean
test_class.var_name: closed
test_class.declarator: resource
test_class.original_string: ManagedTest.Resource resource;
test_class.type: ManagedTest.Resource
test_class.var_name: resource
test_class.file: cyclops-reactor-integration/src/test/java/cyclops/reactive/FluxManagedTest.java
test_class.identifier: FluxManagedTest
test_case.body: @Test
      public void flatMap2() throws InterruptedException {
          Try<Future<String>, Throwable> t = acquireNamed("hello").flatMap(i -> acquireNamed(i.getOrElse("")+ " world").flatMap(f->acquireNamed(f.getOrElse("")+"dude"))).run();
          assertTrue(t.isSuccess());
          assertThat(t.orElse(null).orElse("-1"),equalTo("hello worlddude".toUpperCase()));
  
      }
test_case.class_method_signature: FluxManagedTest.flatMap2()
test_case.full_signature: @Test public void flatMap2()
test_case.identifier: flatMap2
test_case.invocations: run flatMap acquireNamed flatMap acquireNamed getOrElse acquireNamed getOrElse assertTrue isSuccess assertThat orElse orElse equalTo toUpperCase
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void flatMap2()
focal_class.file: cyclops-reactor-integration/src/main/java/cyclops/reactive/FluxManaged.java
focal_class.identifier: FluxManaged
focal_class.class_method_signature: FluxManaged.managed(T just,Consumer<T> cleanup)
focal_class.full_signature: public static Managed<T> managed(T just,Consumer<T> cleanup)
focal_class.identifier: managed
focal_class.modifiers: public static
focal_class.parameters: (T just,Consumer<T> cleanup)
focal_class.return: Managed<T>
focal_class.signature: Managed<T> managed(T just,Consumer<T> cleanup)
focal_class.class_method_signature: FluxManaged.of(Supplier<? extends T> s, Consumer<T> cleanup)
focal_class.full_signature: public static Managed<T> of(Supplier<? extends T> s, Consumer<T> cleanup)
focal_class.identifier: of
focal_class.modifiers: public static
focal_class.parameters: (Supplier<? extends T> s, Consumer<T> cleanup)
focal_class.return: Managed<T>
focal_class.signature: Managed<T> of(Supplier<? extends T> s, Consumer<T> cleanup)
focal_class.class_method_signature: FluxManaged.managed(T just)
focal_class.full_signature: public static Managed<T> managed(T just)
focal_class.identifier: managed
focal_class.modifiers: public static
focal_class.parameters: (T just)
focal_class.return: Managed<T>
focal_class.signature: Managed<T> managed(T just)
focal_class.class_method_signature: FluxManaged.of(Supplier<? extends T> s)
focal_class.full_signature: public static Managed<T> of(Supplier<? extends T> s)
focal_class.identifier: of
focal_class.modifiers: public static
focal_class.parameters: (Supplier<? extends T> s)
focal_class.return: Managed<T>
focal_class.signature: Managed<T> of(Supplier<? extends T> s)
focal_class.class_method_signature: FluxManaged.of(Publisher<T> acq)
focal_class.full_signature: public static Managed<T> of(Publisher<T> acq)
focal_class.identifier: of
focal_class.modifiers: public static
focal_class.parameters: (Publisher<T> acq)
focal_class.return: Managed<T>
focal_class.signature: Managed<T> of(Publisher<T> acq)
focal_class.class_method_signature: FluxManaged.semigroup(Semigroup<T> s)
focal_class.full_signature: public final static Semigroup<Managed<T>> semigroup(Semigroup<T> s)
focal_class.identifier: semigroup
focal_class.modifiers: public final static
focal_class.parameters: (Semigroup<T> s)
focal_class.return: Semigroup<Managed<T>>
focal_class.signature: Semigroup<Managed<T>> semigroup(Semigroup<T> s)
focal_class.class_method_signature: FluxManaged.monoid(Monoid<T> s)
focal_class.full_signature: public final static Monoid<Managed<T>> monoid(Monoid<T> s)
focal_class.identifier: monoid
focal_class.modifiers: public final static
focal_class.parameters: (Monoid<T> s)
focal_class.return: Monoid<Managed<T>>
focal_class.signature: Monoid<Managed<T>> monoid(Monoid<T> s)
focal_class.class_method_signature: FluxManaged.of(IO<T> acquire, Consumer<T> cleanup)
focal_class.full_signature: public static Managed<T> of(IO<T> acquire, Consumer<T> cleanup)
focal_class.identifier: of
focal_class.modifiers: public static
focal_class.parameters: (IO<T> acquire, Consumer<T> cleanup)
focal_class.return: Managed<T>
focal_class.signature: Managed<T> of(IO<T> acquire, Consumer<T> cleanup)
focal_class.class_method_signature: FluxManaged.of(IO<T> acquire)
focal_class.full_signature: public static Managed<T> of(IO<T> acquire)
focal_class.identifier: of
focal_class.modifiers: public static
focal_class.parameters: (IO<T> acquire)
focal_class.return: Managed<T>
focal_class.signature: Managed<T> of(IO<T> acquire)
focal_class.class_method_signature: FluxManaged.sequence(Iterable<? extends Managed<T>> all)
focal_class.full_signature: public static Managed<Seq<T>> sequence(Iterable<? extends Managed<T>> all)
focal_class.identifier: sequence
focal_class.modifiers: public static
focal_class.parameters: (Iterable<? extends Managed<T>> all)
focal_class.return: Managed<Seq<T>>
focal_class.signature: Managed<Seq<T>> sequence(Iterable<? extends Managed<T>> all)
focal_class.class_method_signature: FluxManaged.map(Function<? super T, ? extends R> mapper)
focal_class.full_signature: public Managed<R> map(Function<? super T, ? extends R> mapper)
focal_class.identifier: map
focal_class.modifiers: public
focal_class.parameters: (Function<? super T, ? extends R> mapper)
focal_class.return: Managed<R>
focal_class.signature: Managed<R> map(Function<? super T, ? extends R> mapper)
focal_class.class_method_signature: FluxManaged.flatMap(Function<? super T, cyclops.reactive.Managed<R>> f)
focal_class.full_signature: public Managed<R> flatMap(Function<? super T, cyclops.reactive.Managed<R>> f)
focal_class.identifier: flatMap
focal_class.modifiers: public
focal_class.parameters: (Function<? super T, cyclops.reactive.Managed<R>> f)
focal_class.return: Managed<R>
focal_class.signature: Managed<R> flatMap(Function<? super T, cyclops.reactive.Managed<R>> f)
focal_class.superclass: extends Managed<T>
focal_method.body: public  <R> Managed<R> flatMap(Function<? super T, cyclops.reactive.Managed<R>> f){
  
          FluxManaged<T> m = this;
          return new IO.SyncIO.SyncManaged<R>(){
  
              @Override
              public <R1> IO<R1> apply(Function<? super R, ? extends IO<R1>> fn) {
                  IO<R1> x = m.apply(r1 -> {
                      IO<R1> r = f.apply(r1).apply(r2 -> fn.apply(r2));
                      return r;
                  });
                  return x;
              }
          };
  
      }
focal_method.class_method_signature: FluxManaged.flatMap(Function<? super T, cyclops.reactive.Managed<R>> f)
focal_method.full_signature: public Managed<R> flatMap(Function<? super T, cyclops.reactive.Managed<R>> f)
focal_method.identifier: flatMap
focal_method.invocations: apply apply apply apply
focal_method.modifiers: public
focal_method.parameters: (Function<? super T, cyclops.reactive.Managed<R>> f)
focal_method.return: Managed<R>
focal_method.signature: Managed<R> flatMap(Function<? super T, cyclops.reactive.Managed<R>> f)