test_class.declarator: ex = Executors.newFixedThreadPool(1)
test_class.original_string: Executor ex = Executors.newFixedThreadPool(1);
test_class.type: Executor
test_class.var_name: ex
test_class.declarator: re = new RuntimeException()
test_class.original_string: RuntimeException re = new RuntimeException();
test_class.type: RuntimeException
test_class.var_name: re
test_class.declarator: closed = false
test_class.original_string: boolean closed = false;
test_class.type: boolean
test_class.var_name: closed
test_class.file: cyclops-rxjava2-integration/src/test/java/cyclops/reactive/FlowableIOTest.java
test_class.identifier: FlowableIOTest
test_class.superclass: extends AbstractIOTestBase
test_case.body: @Test
      public void bracket(){
          assertFalse(closed);
          FlowableIO.of(()->10)
              .bracket(i-> new MyCloseable())
              .run();
  
          assertTrue(closed);
      }
test_case.class_method_signature: FlowableIOTest.bracket()
test_case.full_signature: @Test public void bracket()
test_case.identifier: bracket
test_case.invocations: assertFalse run bracket of assertTrue
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void bracket()
focal_class.declarator: flowable
focal_class.modifier: private final
focal_class.original_string: private final Flowable<T> flowable;
focal_class.type: Flowable<T>
focal_class.var_name: flowable
focal_class.file: cyclops-rxjava2-integration/src/main/java/cyclops/reactive/FlowableIO.java
focal_class.identifier: FlowableIO
focal_class.interfaces: implements IO<T>
focal_class.class_method_signature: FlowableIO.of(Flowable<T> flowable)
focal_class.full_signature: public static IO<T> of(Flowable<T> flowable)
focal_class.identifier: of
focal_class.modifiers: public static
focal_class.parameters: (Flowable<T> flowable)
focal_class.return: IO<T>
focal_class.signature: IO<T> of(Flowable<T> flowable)
focal_class.class_method_signature: FlowableIO.of(Future<T> f)
focal_class.full_signature: public static IO<T> of(Future<T> f)
focal_class.identifier: of
focal_class.modifiers: public static
focal_class.parameters: (Future<T> f)
focal_class.return: IO<T>
focal_class.signature: IO<T> of(Future<T> f)
focal_class.class_method_signature: FlowableIO.just(T s)
focal_class.full_signature: public static IO<T> just(T s)
focal_class.identifier: just
focal_class.modifiers: public static
focal_class.parameters: (T s)
focal_class.return: IO<T>
focal_class.signature: IO<T> just(T s)
focal_class.class_method_signature: FlowableIO.of(Supplier<? extends T> s)
focal_class.full_signature: public static IO<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: IO<T>
focal_class.signature: IO<T> of(Supplier<? extends T> s)
focal_class.class_method_signature: FlowableIO.of(Supplier<? extends T> s, Scheduler ex)
focal_class.full_signature: public static IO<T> of(Supplier<? extends T> s, Scheduler ex)
focal_class.identifier: of
focal_class.modifiers: public static
focal_class.parameters: (Supplier<? extends T> s, Scheduler ex)
focal_class.return: IO<T>
focal_class.signature: IO<T> of(Supplier<? extends T> s, Scheduler ex)
focal_class.class_method_signature: FlowableIO.fromPublisher(Publisher<T> p)
focal_class.full_signature: public static IO<T> fromPublisher(Publisher<T> p)
focal_class.identifier: fromPublisher
focal_class.modifiers: public static
focal_class.parameters: (Publisher<T> p)
focal_class.return: IO<T>
focal_class.signature: IO<T> fromPublisher(Publisher<T> p)
focal_class.class_method_signature: FlowableIO.withCatch(Try.CheckedSupplier<T, X> cf, Class<? extends X>... classes)
focal_class.full_signature: public static IO<Try<T,X>> withCatch(Try.CheckedSupplier<T, X> cf, Class<? extends X>... classes)
focal_class.identifier: withCatch
focal_class.modifiers: public static
focal_class.parameters: (Try.CheckedSupplier<T, X> cf, Class<? extends X>... classes)
focal_class.return: IO<Try<T,X>>
focal_class.signature: IO<Try<T,X>> withCatch(Try.CheckedSupplier<T, X> cf, Class<? extends X>... classes)
focal_class.class_method_signature: FlowableIO.merge(Publisher<T1> p1, Publisher<T2> p2, BiFunction<? super T1, ? super T2, ? extends R> fn2)
focal_class.full_signature: public static IO<R> merge(Publisher<T1> p1, Publisher<T2> p2, BiFunction<? super T1, ? super T2, ? extends R> fn2)
focal_class.identifier: merge
focal_class.modifiers: public static
focal_class.parameters: (Publisher<T1> p1, Publisher<T2> p2, BiFunction<? super T1, ? super T2, ? extends R> fn2)
focal_class.return: IO<R>
focal_class.signature: IO<R> merge(Publisher<T1> p1, Publisher<T2> p2, BiFunction<? super T1, ? super T2, ? extends R> fn2)
focal_class.class_method_signature: FlowableIO.par(IO<B> that, BiFunction<? super T, ? super B, ? extends R> fn)
focal_class.full_signature: @Override public IO<R> par(IO<B> that, BiFunction<? super T, ? super B, ? extends R> fn)
focal_class.identifier: par
focal_class.modifiers: @Override public
focal_class.parameters: (IO<B> that, BiFunction<? super T, ? super B, ? extends R> fn)
focal_class.return: IO<R>
focal_class.signature: IO<R> par(IO<B> that, BiFunction<? super T, ? super B, ? extends R> fn)
focal_class.class_method_signature: FlowableIO.race(IO<T> that)
focal_class.full_signature: @Override public IO<T> race(IO<T> that)
focal_class.identifier: race
focal_class.modifiers: @Override public
focal_class.parameters: (IO<T> that)
focal_class.return: IO<T>
focal_class.signature: IO<T> race(IO<T> that)
focal_class.class_method_signature: FlowableIO.map(Function<? super T, ? extends R> s)
focal_class.full_signature: @Override public IO<R> map(Function<? super T, ? extends R> s)
focal_class.identifier: map
focal_class.modifiers: @Override public
focal_class.parameters: (Function<? super T, ? extends R> s)
focal_class.return: IO<R>
focal_class.signature: IO<R> map(Function<? super T, ? extends R> s)
focal_class.class_method_signature: FlowableIO.flatMap(Function<? super T, IO<? extends R>> s)
focal_class.full_signature: @Override public IO<R> flatMap(Function<? super T, IO<? extends R>> s)
focal_class.identifier: flatMap
focal_class.modifiers: @Override public
focal_class.parameters: (Function<? super T, IO<? extends R>> s)
focal_class.return: IO<R>
focal_class.signature: IO<R> flatMap(Function<? super T, IO<? extends R>> s)
focal_class.class_method_signature: FlowableIO.mergeMap(int maxConcurrency, Function<? super T, Publisher<? extends R>> s)
focal_class.full_signature: @Override public IO<R> mergeMap(int maxConcurrency, Function<? super T, Publisher<? extends R>> s)
focal_class.identifier: mergeMap
focal_class.modifiers: @Override public
focal_class.parameters: (int maxConcurrency, Function<? super T, Publisher<? extends R>> s)
focal_class.return: IO<R>
focal_class.signature: IO<R> mergeMap(int maxConcurrency, Function<? super T, Publisher<? extends R>> s)
focal_class.class_method_signature: FlowableIO.bracket(Function<? super T, ? extends R> fn)
focal_class.full_signature: @Override public IO<R> bracket(Function<? super T, ? extends R> fn)
focal_class.identifier: bracket
focal_class.modifiers: @Override public
focal_class.parameters: (Function<? super T, ? extends R> fn)
focal_class.return: IO<R>
focal_class.signature: IO<R> bracket(Function<? super T, ? extends R> fn)
focal_class.class_method_signature: FlowableIO.bracket(Function<? super T, ? extends R> fn, Consumer<R> consumer)
focal_class.full_signature: @Override public IO<R> bracket(Function<? super T, ? extends R> fn, Consumer<R> consumer)
focal_class.identifier: bracket
focal_class.modifiers: @Override public
focal_class.parameters: (Function<? super T, ? extends R> fn, Consumer<R> consumer)
focal_class.return: IO<R>
focal_class.signature: IO<R> bracket(Function<? super T, ? extends R> fn, Consumer<R> consumer)
focal_class.class_method_signature: FlowableIO.bracketWith(Function<? super T, ? extends R> fn, Function<? super R, ? extends R1> with)
focal_class.full_signature: @Override public Managed.Tupled<R,R1> bracketWith(Function<? super T, ? extends R> fn, Function<? super R, ? extends R1> with)
focal_class.identifier: bracketWith
focal_class.modifiers: @Override public
focal_class.parameters: (Function<? super T, ? extends R> fn, Function<? super R, ? extends R1> with)
focal_class.return: Managed.Tupled<R,R1>
focal_class.signature: Managed.Tupled<R,R1> bracketWith(Function<? super T, ? extends R> fn, Function<? super R, ? extends R1> with)
focal_class.class_method_signature: FlowableIO.forEach(Consumer<? super T> consumerElement, Consumer<? super Throwable> consumerError, Runnable onComplete)
focal_class.full_signature: @Override public void forEach(Consumer<? super T> consumerElement, Consumer<? super Throwable> consumerError, Runnable onComplete)
focal_class.identifier: forEach
focal_class.modifiers: @Override public
focal_class.parameters: (Consumer<? super T> consumerElement, Consumer<? super Throwable> consumerError, Runnable onComplete)
focal_class.return: void
focal_class.signature: void forEach(Consumer<? super T> consumerElement, Consumer<? super Throwable> consumerError, Runnable onComplete)
focal_class.class_method_signature: FlowableIO.future()
focal_class.full_signature: @Override public Future<T> future()
focal_class.identifier: future
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Future<T>
focal_class.signature: Future<T> future()
focal_class.class_method_signature: FlowableIO.publisher()
focal_class.full_signature: @Override public Publisher<T> publisher()
focal_class.identifier: publisher
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Publisher<T>
focal_class.signature: Publisher<T> publisher()
focal_class.class_method_signature: FlowableIO.stream()
focal_class.full_signature: @Override public ReactiveSeq<T> stream()
focal_class.identifier: stream
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: ReactiveSeq<T>
focal_class.signature: ReactiveSeq<T> stream()
focal_class.class_method_signature: FlowableIO.unit(Publisher<R> pub)
focal_class.full_signature: @Override public IO<R> unit(Publisher<R> pub)
focal_class.identifier: unit
focal_class.modifiers: @Override public
focal_class.parameters: (Publisher<R> pub)
focal_class.return: IO<R>
focal_class.signature: IO<R> unit(Publisher<R> pub)
focal_method.body: @Override
      public <R extends AutoCloseable> IO<R> bracket(Function<? super T, ? extends R> fn) {
          Managed<R> m = FlowableManaged.of(map(fn));
          return m.io();
      }
focal_method.class_method_signature: FlowableIO.bracket(Function<? super T, ? extends R> fn)
focal_method.full_signature: @Override public IO<R> bracket(Function<? super T, ? extends R> fn)
focal_method.identifier: bracket
focal_method.invocations: of map io
focal_method.modifiers: @Override public
focal_method.parameters: (Function<? super T, ? extends R> fn)
focal_method.return: IO<R>
focal_method.signature: IO<R> bracket(Function<? super T, ? extends R> fn)