Skip to content

Instantly share code, notes, and snippets.

@jeanqasaur
Created April 26, 2021 23:48
Show Gist options
  • Save jeanqasaur/ce4cb86ce560ec312d923cdc563729a7 to your computer and use it in GitHub Desktop.
Save jeanqasaur/ce4cb86ce560ec312d923cdc563729a7 to your computer and use it in GitHub Desktop.
How we implement the StreamFactory interface at Akita
func (fact *tcpStreamFactory) New(netFlow, tcpFlow gopacket.Flow, _ *layers.TCP, _ reassembly.AssemblerContext) reassembly.Stream {
return newTCPStream(fact.clock, netFlow, fact.outChan, fact.fs)
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment