Options
All
  • Public
  • Public/Protected
  • All
Menu

Interface ChannelWrapper<T>

This interface describe a class that will wrap a channel to simplify and reduce the allowed operation Library's users will use ChannelWrappers instead of Channels

Type parameters

  • T

Hierarchy

  • ChannelWrapper

Implemented by

Index

Properties

Methods

Properties

__@asyncIterator

__@asyncIterator: function

Type declaration

    • (): AsyncIterableIterator<T>

    • Returns AsyncIterableIterator<T>

Methods

drain

  • drain(): Promise<T[]>

getInnerChannel

put

  • put(msg: T): Promise<void>

take

  • take(): Promise<T>

Generated using TypeDoc