Skip to content

Commit f17030b

Browse files
authored
Implement read1 method for InputStream (#149)
* Implemented read1 method for InputStream * implemented read1 method using aliasing.
1 parent 8fb366b commit f17030b

File tree

2 files changed

+17
-0
lines changed

2 files changed

+17
-0
lines changed

azure/functions/blob.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,9 @@ def metadata(self):
4545
def read(self, size=-1) -> bytes:
4646
return self._io.read(size)
4747

48+
# implemented read1 method using aliasing.
49+
read1 = read
50+
4851
def readable(self) -> bool:
4952
return True
5053

tests/test_blob.py

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -166,6 +166,20 @@ def test_blob_incomplete_read(self):
166166

167167
self.assertEqual(result.read(size=3), b'blo')
168168

169+
def test_blob_incomplete_read1(self):
170+
datum: Datum = Datum(value=b'blob_content', type='bytes')
171+
result: InputStream = afb.BlobConverter.decode(
172+
data=datum, trigger_metadata=None)
173+
174+
self.assertEqual(result.read1(size=3), b'blo')
175+
176+
def test_blob_complete_read1(self):
177+
datum: Datum = Datum(value=b'blob_content', type='bytes')
178+
result: InputStream = afb.BlobConverter.decode(
179+
data=datum, trigger_metadata=None)
180+
181+
self.assertEqual(result.read1(), b'blob_content')
182+
169183
def test_blob_output_custom_output_content(self):
170184
class CustomOutput:
171185
def read(self) -> bytes:

0 commit comments

Comments
 (0)