Pipeline class abstract

Implementers
Annotations
  • @SPI(name: "mpi")

Constructors

Pipeline()

Properties

hashCode int
The hash code for this object.
no setterinherited
runtimeType Type
A representation of the runtime type of the object.
no setterinherited

Methods

noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
peek(String topic, {Context? ctx}) Future<Uint8List?>
Peek Retrieves, but does not remove, the head of this queue, or returns None if this queue is empty.
pop(Duration timeout, String topic, {Context? ctx}) Future<Uint8List?>
Pop Retrieves and removes the head of this queue, or returns None if this queue is empty.
push(Uint8List payload, Map<String, String> metadata, String topic, {Context? ctx}) Future<void>
Push Inserts the specified element into this queue if it is possible to do so immediately without violating capacity restrictions. When using a capacity-restricted queue, this method is generally preferable to add, which can fail to insert an element only by throwing an exception.
release(Duration timeout, String topic, {Context? ctx}) Future<void>
Release the channel session.
toString() String
A string representation of this object.
inherited

Operators

operator ==(Object other) bool
The equality operator.
inherited