Interface EventSink<T>

All Known Subinterfaces:
ConnectableEventSink<T>
All Known Implementing Classes:
ConnectableEventSource, EventSource
public interface EventSink<T>

  • Method Summary

    Modifier and Type
    Method
    Description
    default Subscription
    feedFrom(EventStream<? extends T> source)
    Starts pushing all events emitted by source to this event sink.
    void
    push(T value)
     

  • Method Details

    • push

      void push(T value)

    • feedFrom

      default Subscription feedFrom(EventStream<? extends T> source)
      Starts pushing all events emitted by source to this event sink.

      An event sink can be fed from multiple sources at the same time.

      sink.feedFrom(stream) is equivalent to stream.feedTo(sink)

      Parameters:
      source - event stream whose events will be pushed to this event sink
      Returns:
      subscription that can be used to stop delivering source's events to this event sink.
      See Also: