jspubsub

Documentation

Index

• type BridgedSubscription
  • func (bs *BridgedSubscription) Cancel()
  • func (bs *BridgedSubscription) Next(ctx context.Context) (pubsubinterfaces.Message, error)
  • func (bs *BridgedSubscription) QueueJS(msg js.Value)
• type PubSubBridge
  • func NewPubSubBridge(jspubsub js.Value) *PubSubBridge
  • func (psb *PubSubBridge) Publish(topic string, data []byte) error
  • func (psb *PubSubBridge) Subscribe(topic string) (pubsubinterfaces.Subscription, error)

Types

type BridgedSubscription

type BridgedSubscription struct {
	pubsubinterfaces.Subscription
	// contains filtered or unexported fields
}

func (*BridgedSubscription) Cancel

func (bs *BridgedSubscription) Cancel()

func (*BridgedSubscription) Next

func (bs *BridgedSubscription) Next(ctx context.Context) (pubsubinterfaces.Message, error)

func (*BridgedSubscription) QueueJS

func (bs *BridgedSubscription) QueueJS(msg js.Value)

type PubSubBridge

type PubSubBridge struct {
	pubsubinterfaces.Pubsubber
	// contains filtered or unexported fields
}

PubSubBridge is a bridge where golang (in wasm) can use the underlying javascript pubsub for (for example) the tupelo client

func NewPubSubBridge

func NewPubSubBridge(jspubsub js.Value) *PubSubBridge

func (*PubSubBridge) Publish

func (psb *PubSubBridge) Publish(topic string, data []byte) error

func (*PubSubBridge) Subscribe

func (psb *PubSubBridge) Subscribe(topic string) (pubsubinterfaces.Subscription, error)