Example of using StreamFactory, StreamPool, and Assembler for TCP packet parsing

parsing_example.go

func (p *NetworkTrafficParser) ParseFromInterface(
	interfaceName, bpfFilter string, signalClose <-chan struct{},
	fs ...akinet.TCPParserFactory) 
(<-chan akinet.ParsedNetworkTraffic, error) {
	// Read in packets, pass to assembler
	packets, err := p.pcap.capturePackets(signalClose,
					      interfaceName,
					      bpfFilter)
	if err != nil {
		return nil, errors.Wrapf(
			err, "failed begin capturing packets from %s", 
			interfaceName)
	}

	// Set up assembly
	out := make(chan akinet.ParsedNetworkTraffic, 100)
	streamFactory := newTCPStreamFactory(
		p.clock, out, akinet.TCPParserFactorySelector(fs))
	streamPool := reassembly.NewStreamPool(streamFactory)
	assembler := reassembly.NewAssembler(streamPool)
  ...