stream2

type Plug struct {
	ResolveStream func(net gopacket.Flow, transport gopacket.Flow, r io.Reader)

	InternalPlugList map[string]PlugInterface
}

type PlugInterface interface {
	ResolveStream(net gopacket.Flow, transport gopacket.Flow, r io.Reader)
}

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

type ProtocolStreamFactory struct {
	Plug *Plug
}