Interface StreamEmitter<T>

Type Parameters:
T - item type
public interface StreamEmitter<T>
Backpressure-aware stream item emitter.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    emit(T item, Duration timeout)
    Emits one item.

  • Method Details

    • emit

      void emit(T item, Duration timeout)
      Emits one item.
      Parameters:
      item - item
      timeout - maximum wait for backpressure capacity