udp

Documentation

Index

• type NullByteReceiveStrategy
  • func (s *NullByteReceiveStrategy) CanReceive(message []byte) bool
  • func (s *NullByteReceiveStrategy) Receive(msg []byte) message.MessageInterface
• type UdpReceiver
  • func NewUdpReceiver(host string, port int, maxPacketSize int, ...) *UdpReceiver
  • func (r *UdpReceiver) Receive()

Types

type NullByteReceiveStrategy

type NullByteReceiveStrategy struct {
}

func (*NullByteReceiveStrategy) CanReceive

func (s *NullByteReceiveStrategy) CanReceive(message []byte) bool

func (*NullByteReceiveStrategy) Receive

func (s *NullByteReceiveStrategy) Receive(msg []byte) message.MessageInterface

type UdpReceiver

type UdpReceiver struct {
	util.Observable
	// contains filtered or unexported fields
}

func NewUdpReceiver

func NewUdpReceiver(
	host string,
	port int,
	maxPacketSize int,
	receiveStrategy receiver.ReceiveStrategy,
) *UdpReceiver

func (*UdpReceiver) Receive

func (r *UdpReceiver) Receive()