Class: LanguageOperator::Agent::StreamingBody::MockStream

Inherits:
Object
  • Object
show all
Defined in:
lib/language_operator/agent/web_server.rb

Overview

Mock stream for testing

Instance Method Summary collapse

Constructor Details

#initialize(buffer) ⇒ MockStream

Returns a new instance of MockStream.



1187
1188
1189
1190
 
# File 'lib/language_operator/agent/web_server.rb', line 1187

def initialize(buffer)
  @buffer = buffer
  @closed = false
end

Instance Method Details

#close ⇒ Object 



1202
1203
1204
 
# File 'lib/language_operator/agent/web_server.rb', line 1202

def close
  @closed = true
end

#closed? ⇒ Boolean

Returns:

  • (Boolean) 


1206
1207
1208
 
# File 'lib/language_operator/agent/web_server.rb', line 1206

def closed?
  @closed
end

#flush ⇒ Object 



1198
1199
1200
 
# File 'lib/language_operator/agent/web_server.rb', line 1198

def flush
  @buffer.flush if @buffer.respond_to?(:flush)
end

#sync ⇒ Object

rubocop:disable Naming/PredicateMethod



1215
1216
1217
 
# File 'lib/language_operator/agent/web_server.rb', line 1215

def sync
  true
end

#sync=(value) ⇒ Object 



1210
1211
1212
 
# File 'lib/language_operator/agent/web_server.rb', line 1210

def sync=(value)
  # No-op for compatibility
end

#write(data) ⇒ Object

Raises:

  • (IOError) 


1192
1193
1194
1195
1196
 
# File 'lib/language_operator/agent/web_server.rb', line 1192

def write(data)
  raise IOError, 'closed stream' if @closed

  @buffer.write(data)
end