Crate wick_packet

wick-packet

The wick-packet crate supplies the data structures necessary to invoke Wick components.

Macros

• fan_out
• packet_stream
• packets

Structs

• ComponentReference
  An implementation that encapsulates a collection link that components use to call out to components on other Wick collections.
• FluxChannel
  An implementation of the Flux as seen in RSocket and reactive streams. It is similar to a [Stream<Item = Result<Item, Err>>] or an unbounded channel.
• FluxPipe
  A FluxPipe is the result of piping one [Flux] into another.
• FluxReceiver
  The receving end-only of a crate::Flux
• InherentData
  Data inherent to an invocation. Meant to be supplied by a runtime, not a user.
• Metadata
  Metadata associated with the frame.
• Mono
  An implementation of Mono as seen in RSocket and reactive streams. It is similar to a [Future<Output = Result<Item, Err>>] that can be pushed to after instantiation.
• Output
• Packet
• PacketError
• PacketStream
  A stream of Packets
• StreamMap
  A wrapper for a map of Strings to [MessageTransport]
• TypeWrapper
• WickMetadata

Enums

• Entity
  The entity being referenced across systems or services.
• Error
  Errors originating from WASM components.
• Flags
• PacketPayload
• ParseError
  The error type for Wick Entities.
• Signal
  The Signal is the wrapper payload that wasmrx types pass around.

Constants

• CLOSE_BRACKET
• DONE_FLAG
• OPEN_BRACKET

Traits

• Flux
  A generic trait to wrap over Flux, Mono, and supporting types.
• MonoFuture
  A Future that wraps a Result and can be used as a Mono.
• Observable
  The wasmrs-rx implementation of an Rx Observable trait
• Observer
  The wasmrs-rx implementation of an Rx Observer trait

Functions

• from_raw_wasmrs
• from_wasmrs
• into_wasmrs

Type Definitions

• BoxFlux
  A utility type for a boxed stream.
• BoxMono
  A utility type for a boxed future.
• FluxBox
  A pinned, boxed [Flux].
• PacketSender