anchor.diff:      },
       messages:encode_msg(Message).
   
  +
   open(Conn, FileGuid) ->
       open(Conn, FileGuid, 'READ_WRITE').
   
  
positive.code:     ?assertMatch(#'ServerMessage'{message_body = {
          fuse_response, #'FuseResponse'{status = #'Status'{code = ok}}
      }, message_id = MsgId}, receive_server_message()).
  
  emit_file_read_event(Conn, StreamId, Seq, FileGuid, Blocks) ->
      {BlocksRead, BlocksSize} = lists:foldr(fun({Offset, Size}, {AccBlocks, AccSize}) ->
  
negative.code:     }, message_id = MsgId}, receive_server_message()),
  
      Data.
  
  
  proxy_write(Conn, FileGuid, HandleId, Offset, Data) ->
      proxy_write(Conn, FileGuid, HandleId, Offset, Data, ?MSG_ID).
  