From c29f60ea345e123256c8eb165899ea7e981e323a Mon Sep 17 00:00:00 2001 From: alisdair sullivan Date: Sun, 30 May 2010 15:58:28 -0700 Subject: [PATCH] changed end of tokenizing marker --- examples/jsx_parser.erl | 2 +- examples/jsx_prettify.erl | 2 +- examples/jsx_stream_parser.erl | 2 +- src/jsx.erl | 16 ++++++++-------- 4 files changed, 11 insertions(+), 11 deletions(-) diff --git a/examples/jsx_parser.erl b/examples/jsx_parser.erl index 7fd6c99..46ffc1f 100644 --- a/examples/jsx_parser.erl +++ b/examples/jsx_parser.erl @@ -79,7 +79,7 @@ event({Type, Value}, [{key, Key}, Object|Stack]) -> event({Type, Value}, [Array|Stack]) when is_list(Array) -> [[?MODULE:Type(Value)] ++ Array] ++ Stack; -event(completed_parse, [Stack]) -> +event(end_of_stream, [Stack]) -> Stack. diff --git a/examples/jsx_prettify.erl b/examples/jsx_prettify.erl index 90b8007..7c30c00 100644 --- a/examples/jsx_prettify.erl +++ b/examples/jsx_prettify.erl @@ -85,7 +85,7 @@ jsx_event({Type, Value}, {Acc, Indent, Level, new}) -> jsx_event({Type, Value}, {Acc, Indent, Level, key}) -> {Acc ++ format(Type, Value), Indent, Level, value}; -jsx_event(completed_parse, {Acc, _, _, _}) -> +jsx_event(end_of_stream, {Acc, _, _, _}) -> Acc. diff --git a/examples/jsx_stream_parser.erl b/examples/jsx_stream_parser.erl index 0e28888..77212a0 100644 --- a/examples/jsx_stream_parser.erl +++ b/examples/jsx_stream_parser.erl @@ -57,7 +57,7 @@ event({key, "_id"}, 1) -> event({string, String}, capture) -> throw({ok, String}); -event(completed_parse, _) -> +event(end_of_stream, _) -> throw(not_found); event(_, Level) -> diff --git a/src/jsx.erl b/src/jsx.erl index 3d7b896..853d326 100644 --- a/src/jsx.erl +++ b/src/jsx.erl @@ -91,7 +91,7 @@ decoder() -> decoder([]). decoder(Opts) -> - F = fun(completed_parse, State) -> lists:reverse(State) ;(Event, State) -> [Event] ++ State end, + F = fun(end_of_stream, State) -> lists:reverse(State) ;(Event, State) -> [Event] ++ State end, decoder({F, []}, Opts). decoder({F, _} = Callbacks, OptsList) when is_list(OptsList), is_function(F) -> @@ -166,7 +166,7 @@ maybe_done(<>, [array|_] = Stack, Callbacks, Opts) -> maybe_done(<>, Stack, Callbacks, ?comments_true(Opts)) -> maybe_comment(Rest, fun(Resume) -> maybe_done(Resume, Stack, Callbacks, Opts) end); maybe_done(<<>>, [], Callbacks, Opts) -> - {fold(completed_parse, Callbacks), fun(Stream) -> maybe_done(Stream, [], Callbacks, Opts) end}; + {fold(end_of_stream, Callbacks), fun(Stream) -> maybe_done(Stream, [], Callbacks, Opts) end}; maybe_done(<<>>, Stack, Callbacks, Opts) -> {incomplete, fun(Stream) -> maybe_done(Stream, Stack, Callbacks, Opts) end}. @@ -364,7 +364,7 @@ zero(<>, Stack, Callbacks, Opts, Acc) when ?is_whitespace(S) -> zero(<>, Stack, Callbacks, ?comments_true(Opts), Acc) -> maybe_comment(Rest, fun(Resume) -> zero(Resume, Stack, Callbacks, Opts, Acc) end); zero(<<>>, [], Callbacks, Opts, Acc) -> - {fold(completed_parse, fold({number, lists:reverse(Acc)}, Callbacks)), + {fold(end_of_stream, fold({number, lists:reverse(Acc)}, Callbacks)), fun(Stream) -> zero(Stream, [], Callbacks, Opts, Acc) end}; zero(<<>>, Stack, Callbacks, Opts, Acc) -> {incomplete, fun(Stream) -> zero(Stream, Stack, Callbacks, Opts, Acc) end}. @@ -393,7 +393,7 @@ integer(<>, Stack, Callbacks, Opts, Acc) when ?is_whitespace(S) integer(<>, Stack, Callbacks, ?comments_true(Opts), Acc) -> maybe_comment(Rest, fun(Resume) -> integer(Resume, Stack, Callbacks, Opts, Acc) end); integer(<<>>, [], Callbacks, Opts, Acc) -> - {fold(completed_parse, fold({number, lists:reverse(Acc)}, Callbacks)), + {fold(end_of_stream, fold({number, lists:reverse(Acc)}, Callbacks)), fun(Stream) -> integer(Stream, [], Callbacks, Opts, Acc) end}; integer(<<>>, Stack, Callbacks, Opts, Acc) -> {incomplete, fun(Stream) -> integer(Stream, Stack, Callbacks, Opts, Acc) end}. @@ -419,7 +419,7 @@ fraction(<>, Stack, Callbacks, Opts, Acc) when ?is_whitespace(S) fraction(<>, Stack, Callbacks, ?comments_true(Opts), Acc) -> maybe_comment(Rest, fun(Resume) -> fraction(Resume, Stack, Callbacks, Opts, Acc) end); fraction(<<>>, [], Callbacks, Opts, Acc) -> - {fold(completed_parse, fold({number, lists:reverse(Acc)}, Callbacks)), + {fold(end_of_stream, fold({number, lists:reverse(Acc)}, Callbacks)), fun(Stream) -> fraction(Stream, [], Callbacks, Opts, Acc) end}; fraction(<<>>, Stack, Callbacks, Opts, Acc) -> {incomplete, fun(Stream) -> fraction(Stream, Stack, Callbacks, Opts, Acc) end}. @@ -456,7 +456,7 @@ exp(<>, Stack, Callbacks, ?comments_true(Opts), Acc) -> exp(<>, Stack, Callbacks, Opts, Acc) when ?is_whitespace(S) -> maybe_done(Rest, Stack, fold({number, lists:reverse(Acc)}, Callbacks), Opts); exp(<<>>, [], Callbacks, Opts, Acc) -> - {fold(completed_parse, fold({number, lists:reverse(Acc)}, Callbacks)), + {fold(end_of_stream, fold({number, lists:reverse(Acc)}, Callbacks)), fun(Stream) -> exp(Stream, [], Callbacks, Opts, Acc) end}; exp(<<>>, Stack, Callbacks, Opts, Acc) -> {incomplete, fun(Stream) -> exp(Stream, Stack, Callbacks, Opts, Acc) end}. @@ -551,8 +551,8 @@ maybe_comment_done(<<>>, Resume) -> %% callbacks to our handler are roughly equivalent to a fold over the events, incremental %% rather than all at once. -fold(completed_parse, {F, State}) -> - F(completed_parse, State); +fold(end_of_stream, {F, State}) -> + F(end_of_stream, State); fold(Event, {F, State}) when is_function(F) -> {F, F(Event, State)}.