default -> null; // Or throw an exception if unexpected token
        };
    }

    /**
     * Parses array values from JSON parser.
     *
     * @param jsonParser the JSON parser
     * @return the parsed array as a list
     * @throws IOException if an I/O error occurs
     */
    protected Object parseArray(final JsonParser jsonParser) throws IOException {

    /**
     * Test method for
     * {@link org.codelibs.core.io.PropertiesUtil#store(Properties, java.io.OutputStream, String)}
     * .
     *
     * @throws IOException
     */
    @Test
    public void testStorePropertiesOutputStreamString() throws IOException {
        final Properties outProperties = new Properties();
        outProperties.setProperty("a", "A");

            // May throw due to null user when task executes, which is expected
        }

        assertTrue("scheduleParentGroupLookup should complete without immediate error", true);
    }

    /**
     * Test that empty groupIds list does not schedule any task.
     */
    @Test
    public void test_updateMemberOf_emptyGroupIds_noScheduledTask() throws Exception {

        (thread, throwable) -> thrownByExecutionThread = throwable);
    executionThread.start();
  }

  private static void throwIfSet(Throwable t) throws Throwable {
    if (t != null) {
      throw t;
    }
  }

  public void testStopUnstartedService() throws Exception {
    NoOpService service = new NoOpService();
    RecordingListener listener = RecordingListener.record(service);

    service.stopAsync();

        (thread, throwable) -> thrownByExecutionThread = throwable);
    executionThread.start();
  }

  private static void throwIfSet(Throwable t) throws Throwable {
    if (t != null) {
      throw t;
    }
  }

  public void testStopUnstartedService() throws Exception {
    NoOpService service = new NoOpService();
    RecordingListener listener = RecordingListener.record(service);

    service.stopAsync();

    private DataStoreFactory dataStoreFactory;
    private SystemHelper systemHelper;
    private File tempDir;

    @Override
    protected void setUp(TestInfo testInfo) throws Exception {
        super.setUp(testInfo);
        dataStoreFactory = new DataStoreFactory();
        systemHelper = new SystemHelper() {
            @Override
            public long getCurrentTimeAsLong() {

  /** Guarded by this. */
  private WebSocket webSocket;

  public RtmSession(SlackApi slackApi) {
    this.slackApi = slackApi;
  }

  public void open(String accessToken) throws IOException {
    if (webSocket != null) throw new IllegalStateException();

    RtmStartResponse rtmStartResponse = slackApi.rtmStart(accessToken);
    webSocket = slackApi.rtm(rtmStartResponse.url, this);
  }

 *    libraries may customize this behavior.)
 *
 * A good way to signal a failure is with a synthetic HTTP response:
 *
 * ```kotlin
 *   @Throws(IOException::class)
 *   override fun intercept(chain: Interceptor.Chain): Response {
 *     if (myConfig.isInvalid()) {
 *       return Response.Builder()
 *           .request(chain.request())

        .build();

    try (Response response = client.newCall(request).execute()) {
      if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);

      System.out.println(response.body().string());
    }
  }

  public static void main(String... args) throws Exception {
    new PostString().run();
  }

   */
  @GwtIncompatible
  @J2ktIncompatible
    private void writeObject(ObjectOutputStream stream) throws IOException {
    stream.defaultWriteObject();
    Serialization.writeMultiset(this, stream);
  }

  @GwtIncompatible
  @J2ktIncompatible
    private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
    stream.defaultReadObject();
    int distinctElements = stream.readInt();