stream

Documentation

Index

• type Msg
• type ReplayBundle
• type ResponseUnknownMsg
• type Stream
  • func New(req *pbsubstreamsrpc.Request, client pbsubstreamsrpc.StreamClient, ...) *Stream
  • func (s *Stream) Init() tea.Cmd
  • func (s *Stream) StartStream() tea.Msg
  • func (s *Stream) StreamColor() string
  • func (s *Stream) TargetParallelProcessingBlock() uint64
  • func (s *Stream) Update(msg tea.Msg) tea.Cmd
• type StreamErrorMsg

Types

type Msg

type Msg int

const (
	ConnectingMsg Msg = iota
	ConnectedMsg
	InterruptStreamMsg
	EndOfStreamMsg
	ReplayedMsg
)

type ReplayBundle

type ReplayBundle []any

type ResponseUnknownMsg

type ResponseUnknownMsg string

type Stream

type Stream struct {
	ReplayBundle ReplayBundle
	// contains filtered or unexported fields
}

func New

func New(req *pbsubstreamsrpc.Request, client pbsubstreamsrpc.StreamClient, callOpts []grpc.CallOption) *Stream

func (*Stream) Init

func (s *Stream) Init() tea.Cmd

func (*Stream) StartStream

func (s *Stream) StartStream() tea.Msg

func (*Stream) StreamColor

func (s *Stream) StreamColor() string

func (*Stream) TargetParallelProcessingBlock

func (s *Stream) TargetParallelProcessingBlock() uint64

func (*Stream) Update

func (s *Stream) Update(msg tea.Msg) tea.Cmd

type StreamErrorMsg

type StreamErrorMsg error