Skip to content

Commit dfe9bd4

Browse files
committed
make stream types a subtype of TranscodingStream
1 parent 12b34f3 commit dfe9bd4

File tree

3 files changed

+5
-2
lines changed

3 files changed

+5
-2
lines changed

src/compression.jl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ function ZstdCompression(;level::Integer=DEFAULT_COMPRESSION_LEVEL)
2525
return ZstdCompression(CStream(), level)
2626
end
2727

28-
const ZstdCompressionStream{S} = TranscodingStream{ZstdCompression,S}
28+
const ZstdCompressionStream{S} = TranscodingStream{ZstdCompression,S} where S<:IO
2929

3030
"""
3131
ZstdCompressionStream(stream::IO; kwargs...)

src/decompression.jl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ function ZstdDecompression()
1414
return ZstdDecompression(DStream())
1515
end
1616

17-
const ZstdDecompressionStream{S} = TranscodingStream{ZstdDecompression,S}
17+
const ZstdDecompressionStream{S} = TranscodingStream{ZstdDecompression,S} where S<:IO
1818

1919
"""
2020
ZstdDecompressionStream(stream::IO)

test/runtests.jl

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,9 @@ import TranscodingStreams
77
@test read(ZstdDecompressionStream(IOBuffer(data))) == b"foo"
88
@test read(ZstdDecompressionStream(IOBuffer(vcat(data, data)))) == b"foofoo"
99

10+
@test ZstdCompressionStream <: TranscodingStreams.TranscodingStream
11+
@test ZstdDecompressionStream <: TranscodingStreams.TranscodingStream
12+
1013
TranscodingStreams.test_roundtrip_read(ZstdCompressionStream, ZstdDecompressionStream)
1114
TranscodingStreams.test_roundtrip_write(ZstdCompressionStream, ZstdDecompressionStream)
1215
TranscodingStreams.test_roundtrip_lines(ZstdCompressionStream, ZstdDecompressionStream)

0 commit comments

Comments
 (0)