htwkmooc/codeocean
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Move flush_buffers method in Runner::Connection

Browse Source
This commit is contained in:
Sebastian Serth
2021-10-18 01:22:26 +02:00
parent 696cd6a236
commit 50b62b5703
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
lib/runner/connection.rb
View File

@ -78,6 +78,11 @@ class Runner::Connection
raise NotImplementedError raise NotImplementedError
end end
def flush_buffers
@stdout_callback.call @stdout_buffer.flush unless @stdout_buffer.empty?
@stderr_callback.call @stderr_buffer.flush unless @stderr_buffer.empty?
end
# === WebSocket Callbacks # === WebSocket Callbacks
# These callbacks are executed based on events indicated by Faye WebSockets and are # These callbacks are executed based on events indicated by Faye WebSockets and are
# independent of the JSON specification that is used within the WebSocket once established. # independent of the JSON specification that is used within the WebSocket once established.
@ -162,10 +167,4 @@ class Runner::Connection
def handle_timeout(_event) def handle_timeout(_event)
@status = :timeout @status = :timeout
end end
def flush_buffers
@stdout_callback.call @stdout_buffer.flush unless @stdout_buffer.empty?
@stderr_callback.call @stderr_buffer.flush unless @stderr_buffer.empty?
end
private :flush_buffers
end end