Package com.mewna.catnip.shard.event

Interface MessageConsumer<T>

All Superinterfaces:
AutoCloseable, Closeable
public interface MessageConsumer<T> extends Closeable

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    address()
     
    default io.reactivex.rxjava3.core.Flowable<T>
    asFlowable()
     
    io.reactivex.rxjava3.core.Flowable<T>
    asFlowable(io.reactivex.rxjava3.core.BackpressureStrategy backpressureStrategy)
     
    io.reactivex.rxjava3.core.Observable<T>
    asObservable()
     
    void
    close()
     
    MessageConsumer<T>
    handler(Consumer<T> handler)
     

  • Method Details

    • address

      String address()

    • handler

      MessageConsumer<T> handler(Consumer<T> handler)

    • asObservable

      io.reactivex.rxjava3.core.Observable<T> asObservable()

    • asFlowable

      io.reactivex.rxjava3.core.Flowable<T> asFlowable(io.reactivex.rxjava3.core.BackpressureStrategy backpressureStrategy)

    • asFlowable

      default io.reactivex.rxjava3.core.Flowable<T> asFlowable()

    • close

      void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable