func RegisterDecoder(contentTypestring, decoder func(io.ReadCloser)Decoder)

type Decoder interface {Event()EventNext()boolClose()errorErr()error}

funcNewDecoder¶

func NewDecoder(res *http.Response)Decoder

type Event struct {TypestringData []byte}

type Stream[Tany] struct {// contains filtered or unexported fields}

funcNewStream¶

func NewStream[Tany](decoderDecoder, errerror) *Stream[T]

func (*Stream[T])Close¶

func (s *Stream[T]) Close()error

func (*Stream[T])Current¶

func (s *Stream[T]) Current() T

func (*Stream[T])Err¶

func (s *Stream[T]) Err()error

func (*Stream[T])Next¶

func (s *Stream[T]) Next()bool

Next returns false if the stream has ended or an error occurred.Call Stream.Current() to get the current value.Call Stream.Err() to get the error.

for stream.Next() {data := stream.Current()} if stream.Err() != nil {... }