libduvet - v1.1.0

libduvet/gateway/events

Types

Listener

</>

A listener’s own subject, as feed.subscribe makes it.

pub type Listener =
  process.Subject(feed.FeedMessage)

Values

await_call_ended

</> 
pub fn await_call_ended(
  listener: process.Subject(feed.FeedMessage),
  timeout_ms: Int,
) -> Result(event.CallEndedEvent, Nil)

await_call_incoming

</> 
pub fn await_call_incoming(
  listener: process.Subject(feed.FeedMessage),
  timeout_ms: Int,
) -> Result(event.CallIncomingEvent, Nil)

await_call_ongoing

</> 
pub fn await_call_ongoing(
  listener: process.Subject(feed.FeedMessage),
  timeout_ms: Int,
) -> Result(event.CallOngoingEvent, Nil)

await_call_outgoing

</> 
pub fn await_call_outgoing(
  listener: process.Subject(feed.FeedMessage),
  timeout_ms: Int,
) -> Result(event.CallOutgoingEvent, Nil)

await_close

</> 
pub fn await_close(
  listener: process.Subject(feed.FeedMessage),
  timeout_ms: Int,
) -> Result(envelope.GatewayCloseReason, Nil)

await_failure

</> 
pub fn await_failure(
  listener: process.Subject(feed.FeedMessage),
  timeout_ms: Int,
) -> Result(feed.GatewayConnectFailure, Nil)

await_message_delete

</> 
pub fn await_message_delete(
  listener: process.Subject(feed.FeedMessage),
  timeout_ms: Int,
) -> Result(event.GatewayMessageDelete, Nil)

await_payload

</> 
pub fn await_payload(
  listener: process.Subject(feed.FeedMessage),
  timeout_ms: Int,
) -> Result(envelope.GatewayEventPayload, Nil)

Typed ways to wait for what a client publishes, the counterpart of the Dart package’s GatewayEvents streams. Each call drops what it isn’t waiting for, so use one listener per kind (or read the feed with [next]).

await_ready

</> 
pub fn await_ready(
  listener: process.Subject(feed.FeedMessage),
  timeout_ms: Int,
) -> Result(ready.GatewayReadyData, Nil)

await_resumed

</> 
pub fn await_resumed(
  listener: process.Subject(feed.FeedMessage),
  timeout_ms: Int,
) -> Result(Int, Nil)

await_state

</> 
pub fn await_state(
  listener: process.Subject(feed.FeedMessage),
  timeout_ms: Int,
) -> Result(feed.GatewayConnectionState, Nil)

await_voice_state_update

</> 
pub fn await_voice_state_update(
  listener: process.Subject(feed.FeedMessage),
  timeout_ms: Int,
) -> Result(event.VoiceStateEvent, Nil)

await_voice_video_refused

</> 
pub fn await_voice_video_refused(
  listener: process.Subject(feed.FeedMessage),
  timeout_ms: Int,
) -> Result(event.VoiceVideoRefusedEvent, Nil)

next

</> 
pub fn next(
  listener: process.Subject(feed.FeedMessage),
  timeout_ms: Int,
) -> Result(feed.FeedMessage, Nil)

The next message, whatever it is.

✨ Search Document