stream

type MsgHandler func(context.Context, []byte) error

type Pub interface {
	// Publish publishes data to the channel ch
	// Publish(ctx context.Context, ch string, data []byte) error
	Publish(ctx context.Context, ch string, data []byte) error
}

type Stream interface {
	Pub
	Sub

	// Start does the initialisation work to bootstrap a Stream adapter.
	// For example, this function may open a connection, start an event loop, etc.
	Start(ctx context.Context) error
	// Drain signals to the Stream client/server that inbound messages should
	// no longer be accepted, but outbound messages can still be delivered.
	Drain()
	// Close closes the client/server for both inbound/outbound messages
	Close() error
}

type Sub interface {
	// Subscribe subscribes the message handler h to the channel ch.
	// All subscriptions with the same q will form a queue group.
	// Each message will be delivered to only one subscriber per queue group.
	// Subscribe(q, ch string, h MsgHandler) error
	Subscribe(q, ch string, f MsgHandler, opts ...SubscriptionOption) (Subscription, error)
}

type Subscription interface {
	// Unsubscribe removes interest in the subscription.
	// For durables, it means that the durable interest is also removed from
	// the server. Restarting a durable with the same name will not resume
	// the subscription, it will be considered a new one.
	Unsubscribe() error
}

type SubscriptionOption interface{}