Неожиданный конец потока Android при потоковой передаче JSON

Итак, у меня есть фрагмент кода, в котором я звоню на сервер, чтобы получить большой файл JSON (около 2 МБ), и анализирую его с помощью Jackson JSON Parser. Код работает нормально, но проблема в том, что я иногда получаю IOException "неожиданный конец потока". Итак, я предполагаю, что теряю соединение с эмулятором во время потоковой передачи. Можно ли как-то приостановить трансляцию и возобновить ее? Или переподключиться, а затем возобновить поток? Спасибо.

private void createDatabase(String downloadUrl)
{
    editor = sharedPref.edit();

    String fieldName = "";
    long id = 0;
    String setNumber = "";
    String cardName = "";
    String type = "";
    String attribute = "";
    String level = "";
    String category = "";
    String attack = "";
    String defense = "";
    String description = "";

    try
    {
        if (isOnline())
        {
            url = new URL(downloadUrl);
            connection = (HttpURLConnection) url.openConnection();
            connection.connect();

            jsonfactory = new JsonFactory();
            jsonParser = jsonfactory.createParser(connection.getInputStream());

            while (jsonParser.nextToken() != JsonToken.END_ARRAY)
            {
                if (jsonParser.getCurrentToken() == JsonToken.FIELD_NAME)
                {
                    fieldName = jsonParser.getCurrentName();

                    // if (fieldName.equals("id"))
                    // {
                    // jsonParser.nextToken();
                    // id = jsonParser.getIntValue();
                    // }

                    if (fieldName.equals("Set_Number"))
                    {
                        jsonParser.nextToken();
                        setNumber = jsonParser.getText();
                    }

                    else if (fieldName.equals("Card_Name"))
                    {
                        jsonParser.nextToken();
                        cardName = jsonParser.getText();
                    }

                    else if (fieldName.equals("Type"))
                    {
                        jsonParser.nextToken();
                        type = jsonParser.getText();
                    }

                    else if (fieldName.equals("Attribute"))
                    {
                        jsonParser.nextToken();
                        attribute = jsonParser.getText();
                    }

                    else if (fieldName.equals("Level"))
                    {
                        jsonParser.nextToken();
                        level = jsonParser.getText();
                    }

                    else if (fieldName.equals("Category"))
                    {
                        jsonParser.nextToken();
                        category = jsonParser.getText();
                    }

                    else if (fieldName.equals("Attack"))
                    {
                        jsonParser.nextToken();
                        attack = jsonParser.getText();
                    }

                    else if (fieldName.equals("Defense"))
                    {
                        jsonParser.nextToken();
                        defense = jsonParser.getText();
                    }

                    else if (fieldName.equals("Description"))
                    {
                        jsonParser.nextToken();
                        description = jsonParser.getText();
                    }
                }

                else if (jsonParser.getCurrentToken() == JsonToken.END_OBJECT)
                {
                    id = db.insert(setNumber, cardName, type, attribute, level, category, attack, defense, description);
                    editor.putLong("lastId", id);
                    editor.commit();
                }
            }
        }
    }

    catch (IOException e)
    {
        e.printStackTrace();
    }

    catch (Exception e)
    {
        e.printStackTrace();
    }

    finally
    {
        if (connection != null)
            connection.disconnect();

        if (jsonParser != null)
        {
            try
            {
                jsonParser.close();
            }
            catch (IOException e)
            {
                e.printStackTrace();
            }
        }
    }

    Log.d("lastID", "" + sharedPref.getLong("lastId", -1));
    if (sharedPref.getLong("lastId", -1) == 5980)
    {
        editor.putBoolean("databaseExists", true);
        editor.commit();
    }
}