equal
deleted
inserted
replaced
54 val global_settings = new Event_Bus[Session.Global_Settings.type] |
54 val global_settings = new Event_Bus[Session.Global_Settings.type] |
55 val perspective = new Event_Bus[Session.Perspective.type] |
55 val perspective = new Event_Bus[Session.Perspective.type] |
56 val assignments = new Event_Bus[Session.Assignment.type] |
56 val assignments = new Event_Bus[Session.Assignment.type] |
57 val commands_changed = new Event_Bus[Session.Commands_Changed] |
57 val commands_changed = new Event_Bus[Session.Commands_Changed] |
58 val phase_changed = new Event_Bus[Session.Phase] |
58 val phase_changed = new Event_Bus[Session.Phase] |
|
59 val syslog_messages = new Event_Bus[Isabelle_Process.Result] |
|
60 val raw_output_messages = new Event_Bus[Isabelle_Process.Result] |
59 val raw_messages = new Event_Bus[Isabelle_Process.Message] // potential bottle-neck |
61 val raw_messages = new Event_Bus[Isabelle_Process.Message] // potential bottle-neck |
60 |
62 |
61 |
63 |
62 |
64 |
63 /** buffered command changes (delay_first discipline) **/ |
65 /** buffered command changes (delay_first discipline) **/ |
449 case input: Isabelle_Process.Input => |
451 case input: Isabelle_Process.Input => |
450 raw_messages.event(input) |
452 raw_messages.event(input) |
451 |
453 |
452 case result: Isabelle_Process.Result => |
454 case result: Isabelle_Process.Result => |
453 handle_result(result) |
455 handle_result(result) |
|
456 if (result.is_syslog) syslog_messages.event(result) |
|
457 if (result.is_stdout) raw_output_messages.event(result) |
454 raw_messages.event(result) |
458 raw_messages.event(result) |
455 } |
459 } |
456 |
460 |
457 case bad => System.err.println("session_actor: ignoring bad message " + bad) |
461 case bad => System.err.println("session_actor: ignoring bad message " + bad) |
458 } |
462 } |