// this simply indicates an empty listing
                doClose();
                return null;
            }

            throw e;
        }
        this.fileId = createResp.getFileId();
        this.response = query.getResponse();
        final FileEntry n = advance(false);
        if (n == null) {
            doClose();
        }

        try {
            this.profileSelector = container.lookup(ProfileSelector.class);
            this.logger = ((MutablePlexusContainer) container).getLogger();
        } catch (ComponentLookupException e) {
            throw new IllegalStateException(e);
        }
        this.requestProperties = props;
    }

    @Override
    public Properties getRequestProperties() {
        return requestProperties;
    }

    @Override

      try {
        field.set(instance, value);
      } catch (IllegalAccessException impossible) {
        throw new AssertionError(impossible);
      }
    }

    void set(T instance, int value) {
      try {
        field.set(instance, value);
      } catch (IllegalAccessException impossible) {
        throw new AssertionError(impossible);
      }
    }
  }

                throw new SMBProtocolDecodingException("Test exception in readParametersWireFormat");
            }
            return parametersWireFormatReturn;
        }

        @Override
        protected int readDataWireFormat(byte[] buffer, int bufferIndex, int len) throws SMBProtocolDecodingException {
            if (throwExceptionOnReadData) {

  Table<String, Integer, Character> makeTable() {
    return ArrayTable.create(asList("foo", "bar", "dog"), asList(1, 2, 3));
  }

  @Override
  protected Map<String, Map<Integer, Character>> makeEmptyMap() {
    throw new UnsupportedOperationException();
  }

        int type = SessionServicePacket.readPacketType(bais, buffer, 0);

        assertEquals(0x81, type);
        assertEquals((byte) 0x81, buffer[0]);
    }

    @Test
    @DisplayName("readPacketType should throw IOException on EOF")
    void testReadPacketTypeEOF() {
        ByteArrayInputStream bais = new ByteArrayInputStream(new byte[0]);
        byte[] buffer = new byte[10];

                    true);
        } catch (org.apache.maven.wagon.TransferFailedException e) {
            throw new ArtifactTransferFailedException(getMessage(e, "Error transferring artifact."), e);
        } catch (org.apache.maven.wagon.ResourceDoesNotExistException e) {
            throw new ArtifactDoesNotExistException(getMessage(e, "Requested artifact does not exist."), e);
        }
    }

    @Override

    List<Byte> one = Arrays.asList((byte) 1);
    assertThat(Bytes.toArray(one)).isEqualTo(ARRAY1);

    byte[] array = {(byte) 0, (byte) 1, (byte) 0x55};

    List<Byte> three = Arrays.asList((byte) 0, (byte) 1, (byte) 0x55);
    assertThat(Bytes.toArray(three)).isEqualTo(array);

    assertThat(Bytes.toArray(Bytes.asList(array))).isEqualTo(array);
  }

  public void testToArray_threadSafe() {

    @Override
    public ResultData transform(final ResponseData responseData) {
        if (responseData == null || !responseData.hasResponseBody()) {
            throw new CrawlingAccessException("No response body.");
        }

        final ResultData resultData = new ResultData();
        resultData.setTransformerName(getName());
        try {

            public CrawlingInfo getLast(String sessionId) {
                return null;
            }

            @Override
            public void store(CrawlingInfo entity) {
                throw new RuntimeException("Database error");
            }

            @Override
            public void storeInfo(List<CrawlingInfoParam> crawlingInfoParamList) {
                // Should not be called
            }