1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
|
# frozen_string_literal: true
# Released under the MIT License.
# Copyright, 2023-2025, by Samuel Williams.
require "protocol/http/body/stream"
require "protocol/http/body/readable"
describe Protocol::HTTP::Body::Readable do
let(:body) {subject.new}
it "might not be empty" do
expect(body).not.to be(:empty?)
end
it "should not be ready" do
expect(body).not.to be(:ready?)
end
with "#buffered" do
it "is unable to buffer by default" do
expect(body.buffered).to be_nil
end
end
with "#finish" do
it "should return empty buffered representation" do
expect(body.finish).to be(:empty?)
end
end
with "#call" do
let(:output) {Protocol::HTTP::Body::Buffered.new}
let(:stream) {Protocol::HTTP::Body::Stream.new(nil, output)}
it "can stream (empty) data" do
body.call(stream)
expect(output).to be(:empty?)
end
it "flushes the stream if it is not ready" do
chunks = ["Hello World"]
mock(body) do |mock|
mock.replace(:read) do
chunks.pop
end
mock.replace(:ready?) do
false
end
end
expect(stream).to receive(:flush)
body.call(stream)
end
end
with "#join" do
it "should be nil" do
expect(body.join).to be_nil
end
end
with "#discard" do
it "should read all chunks" do
expect(body).to receive(:read).and_return(nil)
expect(body.discard).to be_nil
end
end
with "#as_json" do
it "generates a JSON representation" do
expect(body.as_json).to have_keys(
class: be == subject.name,
length: be_nil,
stream: be == false,
ready: be == false,
empty: be == false,
)
end
it "generates a JSON string" do
expect(JSON.dump(body)).to be == body.to_json
end
end
with "#rewindable?" do
it "is not rewindable" do
expect(body).not.to be(:rewindable?)
expect(body.rewind).to be == false
end
end
end
|
