Module org.jooq
Package org.jooq.impl

Class DefaultSubscriberProvider<C>

java.lang.Object
org.jooq.impl.DefaultSubscriberProvider<C>
All Implemented Interfaces:
SubscriberProvider<C>
public class DefaultSubscriberProvider<C> extends Object implements SubscriberProvider<C>
A default, context unaware implementation of the SubscriberProvider SPI.
Author:
Lukas Eder

  • Constructor Details

    • DefaultSubscriberProvider

      public DefaultSubscriberProvider()

  • Method Details

    • context

      public final C context()
      Description copied from interface: SubscriberProvider
      Create an empty context.
      Specified by:
      context in interface SubscriberProvider<C>

    • context

      public final C context(org.reactivestreams.Subscriber<?> subscriber)
      Description copied from interface: SubscriberProvider
      Extract a context from an existing Subscriber.
      Specified by:
      context in interface SubscriberProvider<C>

    • subscriber

      public final <T> org.reactivestreams.Subscriber<T> subscriber(Consumer<? super org.reactivestreams.Subscription> onSubscribe, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Runnable onComplete, C context)
      Description copied from interface: SubscriberProvider
      Create a new subscriber from its component implementations and a previous context.
      Specified by:
      subscriber in interface SubscriberProvider<C>
      Parameters:
      onSubscribe - The implementation of Subscriber.onSubscribe(Subscription)
      onNext - The implementation of Subscriber.onNext(Object)
      onError - The implementation of Subscriber.onError(Throwable)
      onComplete - The implementation of Subscriber.onComplete()
      context - The SubscriberProvider.context()