http_polling

Mar 22, 2021

Changes in this version

+ var HttpPolling = []byte("http_polling_stream")

+ func SetInputIntervalMillis(input []byte, interval int64) []byte

+ func SetRequestInput(input, requestInput []byte) []byte

+ func SetSkipPublishSameResponse(input []byte, skip bool) []byte

+ type HttpPollingStream struct

+ func New(client httpclient.Client) *HttpPollingStream

+ func (h *HttpPollingStream) Start(input []byte, next chan<- []byte, stop <-chan struct{})

+ func (h *HttpPollingStream) UniqueIdentifier() []byte