stream

type LocalStream struct {
	Streams        map[string]func([]byte) error
	CreatedStreams []string
	Messages       map[string][][]byte
	FailToPublish  bool
	// contains filtered or unexported fields
}

type NATSStream struct {
	// contains filtered or unexported fields
}

type Stream interface {
	CreateStream(ctx context.Context, name string, subjects []string) error
	Subscribe(ctx context.Context, durable string, topic string, handler func([]byte) error) error
	Publish(ctx context.Context, topic string, data []byte) error
}