AmiClient
AmiClient copied to clipboard
#18: Optimize reading and parsing events
Fix of issue #18
- add a concurrent queue with two worker threads
- EventReader: reads incoming events from stream and enqueues them
- EventWorker: dequeues events and parses them into a AmiMessage
- DataEventArgs is extended to directly retrieve the parsed AmiMessage (no additional parsing needed)
- But this also removes the use of Reactive Extensions