Added threading and handling for "begin" and "end" data received.