Packages

quicer

0.0.14
0.4.3 0.2.15 0.2.12 0.2.6 0.2.5 0.0.308 retired 0.0.303 0.0.17 0.0.16 0.0.14 0.0.11 0.0.0

msquic nif binding

HexDocs

Current section

Files

Jump to
Readme
12 Versions
1 Dependency
Dependants
Files
Activity
quicer src quicer_server_stream_callback.erl
Raw

src/quicer_server_stream_callback.erl 

-module(quicer_server_stream_callback).

-export([ new_stream/2

        , handle_stream_data/4

        , shutdown/1

        ]).



new_stream(_Stream, _Opts) ->

    InitState = #{sent_bytes => 0},

    {ok, InitState}.



handle_stream_data(Stream, Bin, _Opts, #{sent_bytes := Cnt} = State) ->

    {ok, Size} = quicer:send(Stream, Bin),

    {ok, State#{ sent_bytes => Cnt + Size}}.



shutdown(Stream) ->

    quicer:async_close_stream(Stream).