umgeher/jsx
0
Fork 0
Code Issues Pull requests Activity

new interruptable api, examples broken for the hojillionth time

Browse source
This commit is contained in:
alisdair sullivan 2010-06-11 21:57:42 -07:00
parent e690d7723a
commit 4286892861
3 changed files with 186 additions and 199 deletions
Download patch file Download diff file Expand all files Collapse all files

252
src/jsx_decoder.erl
View file

@ -27,30 +27,16 @@
-module(?name).
-author("alisdairsullivan@yahoo.ca").
-export([parse/2]).
-include("jsx_decoder.hrl").
-export([parse/3]).
-compile(inline).
-include("jsx_types.hrl").
parse(JSON, {Callback, State}, Opts) ->
parse(Callback, State, fun() -> start(JSON, [], Opts) end, Opts).
parse(Callback, State, F, Opts) ->
case F() of
{incomplete, Next} -> {incomplete, Next}
; {end_json, Next} -> {Callback(end_json, State), Next}
; {error, badjson} -> {error, badjson}
; {Event, Next} -> parse(Callback, Callback(Event, State), Next, Opts)
end.
-spec parse(JSON::json(), Opts::jsx_opts()) -> parser_result().
emit(incomplete, F) ->
{incomplete, F};
emit(end_json, F) ->
{end_json, F};
emit(Event, F) ->
{Event, F}.
parse(JSON, Opts) ->
start(JSON, [], Opts).
%% this code is mostly autogenerated and mostly ugly. apologies. for more insight on
@ -64,9 +50,9 @@ emit(Event, F) ->
start(<<S/?encoding, Rest/binary>>, Stack, Opts) when ?is_whitespace(S) ->
start(Rest, Stack, Opts);
start(<<?start_object/?encoding, Rest/binary>>, Stack, Opts) ->
emit(start_object, fun() -> object(Rest, [key|Stack], Opts) end);
{start_object, fun() -> object(Rest, [key|Stack], Opts) end};
start(<<?start_array/?encoding, Rest/binary>>, Stack, Opts) ->
emit(start_array, fun() -> array(Rest, [array|Stack], Opts) end);
{start_array, fun() -> array(Rest, [array|Stack], Opts) end};
start(<<?quote/?encoding, Rest/binary>>, Stack, Opts) ->
string(Rest, Stack, Opts, []);
start(<<$t/?encoding, Rest/binary>>, Stack, Opts) ->
@ -86,16 +72,16 @@ start(<<?solidus/?encoding, Rest/binary>>, Stack, ?comments_enabled(Opts)) ->
start(Bin, Stack, Opts) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> start(<<Bin/binary, Stream/binary>>, Stack, Opts) end)
; _ -> {incomplete, fun(Stream) -> start(<<Bin/binary, Stream/binary>>, Stack, Opts) end}
end.
maybe_done(<<S/?encoding, Rest/binary>>, Stack, Opts) when ?is_whitespace(S) ->
maybe_done(Rest, Stack, Opts);
maybe_done(<<?end_object/?encoding, Rest/binary>>, [object|Stack], Opts) ->
emit(end_object, fun() -> maybe_done(Rest, Stack, Opts) end);
{end_object, fun() -> maybe_done(Rest, Stack, Opts) end};
maybe_done(<<?end_array/?encoding, Rest/binary>>, [array|Stack], Opts) ->
emit(end_array, fun() -> maybe_done(Rest, Stack, Opts) end);
{end_array, fun() -> maybe_done(Rest, Stack, Opts) end};
maybe_done(<<?comma/?encoding, Rest/binary>>, [object|Stack], Opts) ->
key(Rest, [key|Stack], Opts);
maybe_done(<<?comma/?encoding, Rest/binary>>, [array|_] = Stack, Opts) ->
@ -103,13 +89,13 @@ maybe_done(<<?comma/?encoding, Rest/binary>>, [array|_] = Stack, Opts) ->
maybe_done(<<?solidus/?encoding, Rest/binary>>, Stack, ?comments_enabled(Opts)) ->
maybe_comment(Rest, fun(Resume) -> maybe_done(Resume, Stack, Opts) end);
maybe_done(Bin, [], ?stream_mode(Opts)) ->
emit(end_json, fun() -> start(Bin, [], Opts) end);
{end_json, fun() -> start(Bin, [], Opts) end};
maybe_done(<<>>, [], Opts) ->
emit(end_json, fun() -> emit(incomplete, fun(Stream) -> maybe_done(Stream, [], Opts) end) end);
{end_json, fun() -> {incomplete, fun(Stream) -> maybe_done(Stream, [], Opts) end} end};
maybe_done(Bin, Stack, Opts) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> maybe_done(<<Bin/binary, Stream/binary>>, Stack, Opts) end)
; _ -> {incomplete, fun(Stream) -> maybe_done(<<Bin/binary, Stream/binary>>, Stack, Opts) end}
end.
@ -118,13 +104,13 @@ object(<<S/?encoding, Rest/binary>>, Stack, Opts) when ?is_whitespace(S) ->
object(<<?quote/?encoding, Rest/binary>>, Stack, Opts) ->
string(Rest, Stack, Opts, []);
object(<<?end_object/?encoding, Rest/binary>>, [key|Stack], Opts) ->
emit(end_object, fun() -> maybe_done(Rest, Stack, Opts) end);
{end_object, fun() -> maybe_done(Rest, Stack, Opts) end};
object(<<?solidus/?encoding, Rest/binary>>, Stack, ?comments_enabled(Opts)) ->
maybe_comment(Rest, fun(Resume) -> object(Resume, Stack, Opts) end);
object(Bin, Stack, Opts) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> object(<<Bin/binary, Stream/binary>>, Stack, Opts) end)
; _ -> {incomplete, fun(Stream) -> object(<<Bin/binary, Stream/binary>>, Stack, Opts) end}
end.
@ -145,17 +131,17 @@ array(<<?zero/?encoding, Rest/binary>>, Stack, Opts) ->
array(<<S/?encoding, Rest/binary>>, Stack, Opts) when ?is_nonzero(S) ->
integer(Rest, Stack, Opts, [S]);
array(<<?start_object/?encoding, Rest/binary>>, Stack, Opts) ->
emit(start_object, fun() -> object(Rest, [key|Stack], Opts) end);
{start_object, fun() -> object(Rest, [key|Stack], Opts) end};
array(<<?start_array/?encoding, Rest/binary>>, Stack, Opts) ->
emit(start_array, fun() -> array(Rest, [array|Stack], Opts) end);
{start_array, fun() -> array(Rest, [array|Stack], Opts) end};
array(<<?end_array/?encoding, Rest/binary>>, [array|Stack], Opts) ->
emit(end_array, fun() -> maybe_done(Rest, Stack, Opts) end);
{end_array, fun() -> maybe_done(Rest, Stack, Opts) end};
array(<<?solidus/?encoding, Rest/binary>>, Stack, ?comments_enabled(Opts)) ->
maybe_comment(Rest, fun(Resume) -> array(Resume, Stack, Opts) end);
array(Bin, Stack, Opts) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> array(<<Bin/binary, Stream/binary>>, Stack, Opts) end)
; _ -> {incomplete, fun(Stream) -> array(<<Bin/binary, Stream/binary>>, Stack, Opts) end}
end.
@ -176,15 +162,15 @@ value(<<?zero/?encoding, Rest/binary>>, Stack, Opts) ->
value(<<S/?encoding, Rest/binary>>, Stack, Opts) when ?is_nonzero(S) ->
integer(Rest, Stack, Opts, [S]);
value(<<?start_object/?encoding, Rest/binary>>, Stack, Opts) ->
emit(start_object, fun() -> object(Rest, [key|Stack], Opts) end);
{start_object, fun() -> object(Rest, [key|Stack], Opts) end};
value(<<?start_array/?encoding, Rest/binary>>, Stack, Opts) ->
emit(start_array, fun() -> array(Rest, [array|Stack], Opts) end);
{start_array, fun() -> array(Rest, [array|Stack], Opts) end};
value(<<?solidus/?encoding, Rest/binary>>, Stack, ?comments_enabled(Opts)) ->
maybe_comment(Rest, fun(Resume) -> value(Resume, Stack, Opts) end);
value(Bin, Stack, Opts) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> value(<<Bin/binary, Stream/binary>>, Stack, Opts) end)
; _ -> {incomplete, fun(Stream) -> value(<<Bin/binary, Stream/binary>>, Stack, Opts) end}
end.
@ -197,7 +183,7 @@ colon(<<?solidus/?encoding, Rest/binary>>, Stack, ?comments_enabled(Opts)) ->
colon(Bin, Stack, Opts) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> colon(<<Bin/binary, Stream/binary>>, Stack, Opts) end)
; _ -> {incomplete, fun(Stream) -> colon(<<Bin/binary, Stream/binary>>, Stack, Opts) end}
end.
@ -210,7 +196,7 @@ key(<<?solidus/?encoding, Rest/binary>>, Stack, ?comments_enabled(Opts)) ->
key(Bin, Stack, Opts) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> key(<<Bin/binary, Stream/binary>>, Stack, Opts) end)
; _ -> {incomplete, fun(Stream) -> key(<<Bin/binary, Stream/binary>>, Stack, Opts) end}
end.
@ -220,9 +206,9 @@ key(Bin, Stack, Opts) ->
%% converted back to lists by the user anyways.
string(<<?quote/?encoding, Rest/binary>>, [key|_] = Stack, Opts, Acc) ->
emit({key, lists:reverse(Acc)}, fun() -> colon(Rest, Stack, Opts) end);
{{key, lists:reverse(Acc)}, fun() -> colon(Rest, Stack, Opts) end};
string(<<?quote/?encoding, Rest/binary>>, Stack, Opts, Acc) ->
emit({string, lists:reverse(Acc)}, fun() -> maybe_done(Rest, Stack, Opts) end);
{{string, lists:reverse(Acc)}, fun() -> maybe_done(Rest, Stack, Opts) end};
string(<<?rsolidus/?encoding, Rest/binary>>, Stack, Opts, Acc) ->
escape(Rest, Stack, Opts, Acc);
string(<<S/?encoding, Rest/binary>>, Stack, Opts, Acc) when ?is_noncontrol(S) ->
@ -230,7 +216,7 @@ string(<<S/?encoding, Rest/binary>>, Stack, Opts, Acc) when ?is_noncontrol(S) ->
string(Bin, Stack, Opts, Acc) ->
case partial_utf(Bin) of
false -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> string(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end)
; _ -> {incomplete, fun(Stream) -> string(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end}
end.
@ -304,7 +290,7 @@ escape(<<S/?encoding, Rest/binary>>, Stack, Opts, Acc)
escape(Bin, Stack, Opts, Acc) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> escape(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end)
; _ -> {incomplete, fun(Stream) -> escape(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end}
end.
@ -354,9 +340,9 @@ escaped_unicode(<<S/?encoding, Rest/binary>>, Stack, Opts, String, Acc) when ?is
escaped_unicode(Bin, Stack, Opts, String, Acc) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) ->
; _ -> {incomplete, fun(Stream) ->
escaped_unicode(<<Bin/binary, Stream/binary>>, Stack, Opts, String, Acc)
end)
end}
end.
%% upon encountering a low pair json/hex encoded value, check to see if there's a high
@ -389,58 +375,58 @@ negative(<<S/?encoding, Rest/binary>>, Stack, Opts, Acc) when ?is_nonzero(S) ->
negative(Bin, Stack, Opts, Acc) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> negative(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end)
; _ -> {incomplete, fun(Stream) -> negative(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end}
end.
zero(<<?end_object/?encoding, Rest/binary>>, [object|Stack], Opts, Acc) ->
emit({integer, lists:reverse(Acc)}, fun() ->
emit(end_object, fun() -> maybe_done(Rest, Stack, Opts) end)
end);
{{integer, lists:reverse(Acc)}, fun() ->
{end_object, fun() -> maybe_done(Rest, Stack, Opts) end}
end};
zero(<<?end_array/?encoding, Rest/binary>>, [array|Stack], Opts, Acc) ->
emit({integer, lists:reverse(Acc)}, fun() ->
emit(end_array, fun() -> maybe_done(Rest, Stack, Opts) end)
end);
{{integer, lists:reverse(Acc)}, fun() ->
{end_array, fun() -> maybe_done(Rest, Stack, Opts) end}
end};
zero(<<?comma/?encoding, Rest/binary>>, [object|Stack], Opts, Acc) ->
emit({integer, lists:reverse(Acc)}, fun() -> key(Rest, [key|Stack], Opts) end);
{{integer, lists:reverse(Acc)}, fun() -> key(Rest, [key|Stack], Opts) end};
zero(<<?comma/?encoding, Rest/binary>>, [array|_] = Stack, Opts, Acc) ->
emit({integer, lists:reverse(Acc)}, fun() -> value(Rest, Stack, Opts) end);
{{integer, lists:reverse(Acc)}, fun() -> value(Rest, Stack, Opts) end};
zero(<<?decimalpoint/?encoding, Rest/binary>>, Stack, Opts, Acc) ->
initial_decimal(Rest, Stack, Opts, [?decimalpoint] ++ Acc);
zero(<<S/?encoding, Rest/binary>>, Stack, Opts, Acc) when ?is_whitespace(S) ->
emit({integer, lists:reverse(Acc)}, fun() -> maybe_done(Rest, Stack, Opts) end);
{{integer, lists:reverse(Acc)}, fun() -> maybe_done(Rest, Stack, Opts) end};
zero(<<?solidus/?encoding, Rest/binary>>, Stack, ?comments_enabled(Opts), Acc) ->
maybe_comment(Rest, fun(Resume) -> zero(Resume, Stack, Opts, Acc) end);
zero(Bin, [], ?stream_mode(Opts), Acc) ->
emit({integer, lists:reverse(Acc)}, fun() ->
emit(end_json, fun() -> start(Bin, [], Opts) end)
end);
{{integer, lists:reverse(Acc)}, fun() ->
{end_json, fun() -> start(Bin, [], Opts) end}
end};
zero(<<>>, [], Opts, Acc) ->
emit({integer, lists:reverse(Acc)}, fun() ->
emit(end_json, fun() -> emit(incomplete, fun(Stream) -> maybe_done(Stream, [], Opts) end)
end)
end);
{{integer, lists:reverse(Acc)}, fun() ->
{end_json, fun() -> {incomplete, fun(Stream) -> maybe_done(Stream, [], Opts) end}
end}
end};
zero(Bin, Stack, Opts, Acc) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> zero(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end)
; _ -> {incomplete, fun(Stream) -> zero(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end}
end.
integer(<<S/?encoding, Rest/binary>>, Stack, Opts, Acc) when ?is_nonzero(S) ->
integer(Rest, Stack, Opts, [S] ++ Acc);
integer(<<?end_object/?encoding, Rest/binary>>, [object|Stack], Opts, Acc) ->
emit({integer, lists:reverse(Acc)}, fun() ->
emit(end_object, fun() -> maybe_done(Rest, Stack, Opts) end)
end);
{{integer, lists:reverse(Acc)}, fun() ->
{end_object, fun() -> maybe_done(Rest, Stack, Opts) end}
end};
integer(<<?end_array/?encoding, Rest/binary>>, [array|Stack], Opts, Acc) ->
emit({integer, lists:reverse(Acc)}, fun() ->
emit(end_array, fun() -> maybe_done(Rest, Stack, Opts) end)
end);
{{integer, lists:reverse(Acc)}, fun() ->
{end_array, fun() -> maybe_done(Rest, Stack, Opts) end}
end};
integer(<<?comma/?encoding, Rest/binary>>, [object|Stack], Opts, Acc) ->
emit({integer, lists:reverse(Acc)}, fun() -> key(Rest, [key|Stack], Opts) end);
{{integer, lists:reverse(Acc)}, fun() -> key(Rest, [key|Stack], Opts) end};
integer(<<?comma/?encoding, Rest/binary>>, [array|_] = Stack, Opts, Acc) ->
emit({integer, lists:reverse(Acc)}, fun() -> value(Rest, Stack, Opts) end);
{{integer, lists:reverse(Acc)}, fun() -> value(Rest, Stack, Opts) end};
integer(<<?decimalpoint/?encoding, Rest/binary>>, Stack, Opts, Acc) ->
initial_decimal(Rest, Stack, Opts, [?decimalpoint] ++ Acc);
integer(<<?zero/?encoding, Rest/binary>>, Stack, Opts, Acc) ->
@ -450,22 +436,22 @@ integer(<<$e/?encoding, Rest/binary>>, Stack, Opts, Acc) ->
integer(<<$E/?encoding, Rest/binary>>, Stack, Opts, Acc) ->
e(Rest, Stack, Opts, "e0." ++ Acc);
integer(<<S/?encoding, Rest/binary>>, Stack, Opts, Acc) when ?is_whitespace(S) ->
emit({integer, lists:reverse(Acc)}, fun() -> maybe_done(Rest, Stack, Opts) end);
{{integer, lists:reverse(Acc)}, fun() -> maybe_done(Rest, Stack, Opts) end};
integer(<<?solidus/?encoding, Rest/binary>>, Stack, ?comments_enabled(Opts), Acc) ->
maybe_comment(Rest, fun(Resume) -> integer(Resume, Stack, Opts, Acc) end);
integer(Bin, [], ?stream_mode(Opts), Acc) ->
emit({integer, lists:reverse(Acc)}, fun() ->
emit(end_json, fun() -> start(Bin, [], Opts) end)
end);
{{integer, lists:reverse(Acc)}, fun() ->
{end_json, fun() -> start(Bin, [], Opts) end}
end};
integer(<<>>, [], Opts, Acc) ->
emit({integer, lists:reverse(Acc)}, fun() ->
emit(end_json, fun() -> emit(incomplete, fun(Stream) -> maybe_done(Stream, [], Opts) end)
end)
end);
{{integer, lists:reverse(Acc)}, fun() ->
{end_json, fun() -> {incomplete, fun(Stream) -> maybe_done(Stream, [], Opts) end}
end}
end};
integer(Bin, Stack, Opts, Acc) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> integer(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end)
; _ -> {incomplete, fun(Stream) -> integer(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end}
end.
@ -476,24 +462,24 @@ initial_decimal(<<?zero/?encoding, Rest/binary>>, Stack, Opts, Acc) ->
initial_decimal(Bin, Stack, Opts, Acc) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> initial_decimal(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end)
; _ -> {incomplete, fun(Stream) -> initial_decimal(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end}
end.
decimal(<<S/?encoding, Rest/binary>>, Stack, Opts, Acc) when ?is_nonzero(S) ->
decimal(Rest, Stack, Opts, [S] ++ Acc);
decimal(<<?end_object/?encoding, Rest/binary>>, [object|Stack], Opts, Acc) ->
emit({float, lists:reverse(Acc)}, fun() ->
emit(end_object, fun() -> maybe_done(Rest, Stack, Opts) end)
end);
{{float, lists:reverse(Acc)}, fun() ->
{end_object, fun() -> maybe_done(Rest, Stack, Opts) end}
end};
decimal(<<?end_array/?encoding, Rest/binary>>, [array|Stack], Opts, Acc) ->
emit({float, lists:reverse(Acc)}, fun() ->
emit(end_array, fun() -> maybe_done(Rest, Stack, Opts) end)
end);
{{float, lists:reverse(Acc)}, fun() ->
{end_array, fun() -> maybe_done(Rest, Stack, Opts) end}
end};
decimal(<<?comma/?encoding, Rest/binary>>, [object|Stack], Opts, Acc) ->
emit({float, lists:reverse(Acc)}, fun() -> key(Rest, [key|Stack], Opts) end);
{{float, lists:reverse(Acc)}, fun() -> key(Rest, [key|Stack], Opts) end};
decimal(<<?comma/?encoding, Rest/binary>>, [array|_] = Stack, Opts, Acc) ->
emit({float, lists:reverse(Acc)}, fun() -> value(Rest, Stack, Opts) end);
{{float, lists:reverse(Acc)}, fun() -> value(Rest, Stack, Opts) end};
decimal(<<?zero/?encoding, Rest/binary>>, Stack, Opts, Acc) ->
decimal(Rest, Stack, Opts, [?zero] ++ Acc);
decimal(<<$e/?encoding, Rest/binary>>, Stack, Opts, Acc) ->
@ -501,22 +487,22 @@ decimal(<<$e/?encoding, Rest/binary>>, Stack, Opts, Acc) ->
decimal(<<$E/?encoding, Rest/binary>>, Stack, Opts, Acc) ->
e(Rest, Stack, Opts, "e" ++ Acc);
decimal(<<S/?encoding, Rest/binary>>, Stack, Opts, Acc) when ?is_whitespace(S) ->
emit({float, lists:reverse(Acc)}, fun() -> maybe_done(Rest, Stack, Opts) end);
{{float, lists:reverse(Acc)}, fun() -> maybe_done(Rest, Stack, Opts) end};
decimal(<<?solidus/?encoding, Rest/binary>>, Stack, ?comments_enabled(Opts), Acc) ->
maybe_comment(Rest, fun(Resume) -> decimal(Resume, Stack, Opts, Acc) end);
decimal(Bin, [], ?stream_mode(Opts), Acc) ->
emit({float, lists:reverse(Acc)}, fun() ->
emit(end_json, fun() -> start(Bin, [], Opts) end)
end);
{{float, lists:reverse(Acc)}, fun() ->
{end_json, fun() -> start(Bin, [], Opts) end}
end};
decimal(<<>>, [], Opts, Acc) ->
emit({float, lists:reverse(Acc)}, fun() ->
emit(end_json, fun() -> emit(incomplete, fun(Stream) -> maybe_done(Stream, [], Opts) end)
end)
end);
{{float, lists:reverse(Acc)}, fun() ->
{end_json, fun() -> {incomplete, fun(Stream) -> maybe_done(Stream, [], Opts) end}
end}
end};
decimal(Bin, Stack, Opts, Acc) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> decimal(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end)
; _ -> {incomplete, fun(Stream) -> decimal(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end}
end.
@ -527,7 +513,7 @@ e(<<S/?encoding, Rest/binary>>, Stack, Opts, Acc) when S =:= ?positive; S =:= ?n
e(Bin, Stack, Opts, Acc) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> e(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end)
; _ -> {incomplete, fun(Stream) -> e(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end}
end.
@ -536,43 +522,43 @@ ex(<<S/?encoding, Rest/binary>>, Stack, Opts, Acc) when S =:= ?zero; ?is_nonzero
ex(Bin, Stack, Opts, Acc) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> ex(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end)
; _ -> {incomplete, fun(Stream) -> ex(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end}
end.
exp(<<S/?encoding, Rest/binary>>, Stack, Opts, Acc) when ?is_nonzero(S) ->
exp(Rest, Stack, Opts, [S] ++ Acc);
exp(<<?end_object/?encoding, Rest/binary>>, [object|Stack], Opts, Acc) ->
emit({float, lists:reverse(Acc)}, fun() ->
emit(end_object, fun() -> maybe_done(Rest, Stack, Opts) end)
end);
{{float, lists:reverse(Acc)}, fun() ->
{end_object, fun() -> maybe_done(Rest, Stack, Opts) end}
end};
exp(<<?end_array/?encoding, Rest/binary>>, [array|Stack], Opts, Acc) ->
emit({float, lists:reverse(Acc)}, fun() ->
emit(end_array, fun() -> maybe_done(Rest, Stack, Opts) end)
end);
{{float, lists:reverse(Acc)}, fun() ->
{end_array, fun() -> maybe_done(Rest, Stack, Opts) end}
end};
exp(<<?comma/?encoding, Rest/binary>>, [object|Stack], Opts, Acc) ->
emit({float, lists:reverse(Acc)}, fun() -> key(Rest, [key|Stack], Opts) end);
{{float, lists:reverse(Acc)}, fun() -> key(Rest, [key|Stack], Opts) end};
exp(<<?comma/?encoding, Rest/binary>>, [array|_] = Stack, Opts, Acc) ->
emit({float, lists:reverse(Acc)}, fun() -> value(Rest, Stack, Opts) end);
{{float, lists:reverse(Acc)}, fun() -> value(Rest, Stack, Opts) end};
exp(<<?zero/?encoding, Rest/binary>>, Stack, Opts, Acc) ->
exp(Rest, Stack, Opts, [?zero] ++ Acc);
exp(<<S/?encoding, Rest/binary>>, Stack, Opts, Acc) when ?is_whitespace(S) ->
emit({float, lists:reverse(Acc)}, fun() -> maybe_done(Rest, Stack, Opts) end);
{{float, lists:reverse(Acc)}, fun() -> maybe_done(Rest, Stack, Opts) end};
exp(<<?solidus/?encoding, Rest/binary>>, Stack, ?comments_enabled(Opts), Acc) ->
maybe_comment(Rest, fun(Resume) -> exp(Resume, Stack, Opts, Acc) end);
exp(Bin, [], ?stream_mode(Opts), Acc) ->
emit({float, lists:reverse(Acc)}, fun() ->
emit(end_json, fun() -> start(Bin, [], Opts) end)
end);
{{float, lists:reverse(Acc)}, fun() ->
{end_json, fun() -> start(Bin, [], Opts) end}
end};
exp(<<>>, [], Opts, Acc) ->
emit({float, lists:reverse(Acc)}, fun() ->
emit(end_json, fun() -> emit(incomplete, fun(Stream) -> maybe_done(Stream, [], Opts) end)
end)
end);
{{float, lists:reverse(Acc)}, fun() ->
{end_json, fun() -> {incomplete, fun(Stream) -> maybe_done(Stream, [], Opts) end}
end}
end};
exp(Bin, Stack, Opts, Acc) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> exp(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end)
; _ -> {incomplete, fun(Stream) -> exp(<<Bin/binary, Stream/binary>>, Stack, Opts, Acc) end}
end.
@ -581,7 +567,7 @@ tr(<<$r/?encoding, Rest/binary>>, Stack, Opts) ->
tr(Bin, Stack, Opts) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> tr(<<Bin/binary, Stream/binary>>, Stack, Opts) end)
; _ -> {incomplete, fun(Stream) -> tr(<<Bin/binary, Stream/binary>>, Stack, Opts) end}
end.
@ -590,16 +576,16 @@ tru(<<$u/?encoding, Rest/binary>>, Stack, Opts) ->
tru(Bin, Stack, Opts) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> tru(<<Bin/binary, Stream/binary>>, Stack, Opts) end)
; _ -> {incomplete, fun(Stream) -> tru(<<Bin/binary, Stream/binary>>, Stack, Opts) end}
end.
true(<<$e/?encoding, Rest/binary>>, Stack, Opts) ->
emit({literal, true}, fun() -> maybe_done(Rest, Stack, Opts) end);
{{literal, true}, fun() -> maybe_done(Rest, Stack, Opts) end};
true(Bin, Stack, Opts) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> true(<<Bin/binary, Stream/binary>>, Stack, Opts) end)
; _ -> {incomplete, fun(Stream) -> true(<<Bin/binary, Stream/binary>>, Stack, Opts) end}
end.
@ -608,7 +594,7 @@ fa(<<$a/?encoding, Rest/binary>>, Stack, Opts) ->
fa(Bin, Stack, Opts) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> fa(<<Bin/binary, Stream/binary>>, Stack, Opts) end)
; _ -> {incomplete, fun(Stream) -> fa(<<Bin/binary, Stream/binary>>, Stack, Opts) end}
end.
@ -617,7 +603,7 @@ fal(<<$l/?encoding, Rest/binary>>, Stack, Opts) ->
fal(Bin, Stack, Opts) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> fal(<<Bin/binary, Stream/binary>>, Stack, Opts) end)
; _ -> {incomplete, fun(Stream) -> fal(<<Bin/binary, Stream/binary>>, Stack, Opts) end}
end.
@ -626,16 +612,16 @@ fals(<<$s/?encoding, Rest/binary>>, Stack, Opts) ->
fals(Bin, Stack, Opts) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> fals(<<Bin/binary, Stream/binary>>, Stack, Opts) end)
; _ -> {incomplete, fun(Stream) -> fals(<<Bin/binary, Stream/binary>>, Stack, Opts) end}
end.
false(<<$e/?encoding, Rest/binary>>, Stack, Opts) ->
emit({literal, false}, fun() -> maybe_done(Rest, Stack, Opts) end);
{{literal, false}, fun() -> maybe_done(Rest, Stack, Opts) end};
false(Bin, Stack, Opts) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> false(<<Bin/binary, Stream/binary>>, Stack, Opts) end)
; _ -> {incomplete, fun(Stream) -> false(<<Bin/binary, Stream/binary>>, Stack, Opts) end}
end.
@ -644,7 +630,7 @@ nu(<<$u/?encoding, Rest/binary>>, Stack, Opts) ->
nu(Bin, Stack, Opts) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> nu(<<Bin/binary, Stream/binary>>, Stack, Opts) end)
; _ -> {incomplete, fun(Stream) -> nu(<<Bin/binary, Stream/binary>>, Stack, Opts) end}
end.
@ -653,16 +639,16 @@ nul(<<$l/?encoding, Rest/binary>>, Stack, Opts) ->
nul(Bin, Stack, Opts) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> nul(<<Bin/binary, Stream/binary>>, Stack, Opts) end)
; _ -> {incomplete, fun(Stream) -> nul(<<Bin/binary, Stream/binary>>, Stack, Opts) end}
end.
null(<<$l/?encoding, Rest/binary>>, Stack, Opts) ->
emit({literal, null}, fun() -> maybe_done(Rest, Stack, Opts) end);
{{literal, null}, fun() -> maybe_done(Rest, Stack, Opts) end};
null(Bin, Stack, Opts) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> null(<<Bin/binary, Stream/binary>>, Stack, Opts) end)
; _ -> {incomplete, fun(Stream) -> null(<<Bin/binary, Stream/binary>>, Stack, Opts) end}
end.
@ -677,7 +663,7 @@ maybe_comment(<<?star/?encoding, Rest/binary>>, Resume) ->
maybe_comment(Bin, Resume) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> maybe_comment(<<Bin/binary, Stream/binary>>, Resume) end)
; _ -> {incomplete, fun(Stream) -> maybe_comment(<<Bin/binary, Stream/binary>>, Resume) end}
end.
@ -688,7 +674,7 @@ comment(<<_/?encoding, Rest/binary>>, Resume) ->
comment(Bin, Resume) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> comment(<<Bin/binary, Stream/binary>>, Resume) end)
; _ -> {incomplete, fun(Stream) -> comment(<<Bin/binary, Stream/binary>>, Resume) end}
end.
@ -699,5 +685,5 @@ maybe_comment_done(<<_/?encoding, Rest/binary>>, Resume) ->
maybe_comment_done(Bin, Resume) ->
case byte_size(Bin) >= ?symbol_size of
true -> {error, badjson}
; _ -> emit(incomplete, fun(Stream) -> maybe_comment_done(<<Bin/binary, Stream/binary>>, Resume) end)
; _ -> {incomplete, fun(Stream) -> maybe_comment_done(<<Bin/binary, Stream/binary>>, Resume) end}
end.