jli  Linuxx86_641.10.3v1.10.30b4590a5507d3f3046e5bafc007cacbbfc9b310bWTestExtRm()Dy~ 97;/opt/julia/packages/TranscodingStreams/o7roJ/ext/TestExt.jl A@ O#e^,Test\Y_ɢ?Random#BŦ&(P;TranscodingStreamsL CoremуJ5Basemу]J5MainmуJ5ArgToolsBń x(mуF K5 Artifactsmr-V3|mу K5Base64UlD*_mу> K5CRC32c\y.jmуj K5 FileWatchingXzsy`{,zmуh& K5LibdluVW59˗,mу-" K5LoggingT{VhUXM=mуrU" K5MmapP~:xg,Omу|' K5NetworkOptionsC0YW,mуʠ, K5SHAQ<$!<%mу1 K5 Serialization [)*k1mу-G K5Sockets1V$ bdސݗmуYBY K5UnicodeP>I>Nrmуeszo K5 LinearAlgebraSm7̏mуuux K5 OpenBLAS_jll[(Śb6EcQ FmуDux K5libblastrampoline_jllLSۆ }lxӠmу^} K5MarkdownZPn7z`smу/Ed~ K5Printfg^cX׸QDmу;h K5Random_ɢ?\Ymу? K5TarOi>աmу!t, K5DatesEY8pj2 mуX K5FuturebS;3{I xVMmуsD K5InteractiveUtilsWL ~@'ZmуVg K5LibGit2Z[&RPTv3EКRmу8J K5 LibGit2_jll YXg}]$mуD K5 MbedTLS_jllAX 3ȡ_mу- K5 LibSSH2_jlloTZk)߆transcode(encoder, x), vcat, chunks, init=UInt8[]) buffer = NoopStream(IOBuffer(data)) ok = true for chunk in chunks stream = TranscodingStream(Decoder(), buffer; stop_on_end=true, sharedbuf) ok &= read(stream) == chunk ok &= position(stream) == length(chunk) ok &= eof(stream) ok &= isreadable(stream) close(stream) end # read without stop_on_end should read the full data. stream = TranscodingStream(Decoder(), IOBuffer(data)) ok &= read(stream) == reduce(vcat, chunks) close(stream) Test.@test ok end end finalize(encoder) end function TranscodingStreams.test_chunked_write(Encoder, Decoder) seed!(TEST_RANDOM_SEED) alpha = b"空即是色" encoder = Encoder() initialize(encoder) for _ in 1:500 chunks = [rand(alpha, rand(0:100)) for _ in 1:2] data = map(x->transcode(encoder, x), chunks) buffer = IOBuffer() stream = TranscodingStream(Decoder(), buffer, stop_on_end=true) write(stream, vcat(data...)) close(stream) ok = true ok &= hash(take!(buffer)) == hash(vcat(chunks...)) ok &= buffersize(stream.state.buffer1) == 0 Test.@test ok end finalize(encoder) end end # module a:7I