System.out.println(i);
            Thread.sleep(10);
            sink.writeUtf8(String.format(" * %s = %s\n", i, factor(i)));
          }
          sink.close();
        } catch (IOException | InterruptedException e) {
          e.printStackTrace();
        }
      }

      private String factor(int n) {
        for (int i = 2; i < n; i++) {
          int x = n / i;

  }

  private static void assertChecksum(ImmutableSupplier<Checksum> supplier, String input) {
    byte[] bytes = HashTestUtils.ascii(input);

    Checksum checksum = supplier.get();
    checksum.update(bytes, 0, bytes.length);
    long value = checksum.getValue();

    String toString = "name";
    HashFunction func = new ChecksumHashFunction(supplier, 32, toString);

class Trans2FindNext2 extends SmbComTransaction {

    private final int sid, informationLevel;
    private int resumeKey;
    private final int flags;
    private String filename;

    Trans2FindNext2(final int sid, final int resumeKey, final String filename) {
        this.sid = sid;
        this.resumeKey = resumeKey;
        this.filename = filename;
        command = SMB_COM_TRANSACTION2;

     * @param msg the error message
     */
    public DcerpcException(final String msg) {
        super(msg);
    }

    /**
     * Constructs a DcerpcException with the specified message and root cause
     *
     * @param msg the error message
     * @param rootCause the underlying cause of this exception
     */
    public DcerpcException(final String msg, final Throwable rootCause) {
        super(msg);

    public Slf4jMavenTransferListener(Logger out) {
        this.out = out;
    }

    @Override
    public void transferInitiated(TransferEvent event) {
        String action = event.getRequestType() == TransferEvent.RequestType.PUT ? "Uploading" : "Downloading";
        String direction = event.getRequestType() == TransferEvent.RequestType.PUT ? "to" : "from";

        TransferResource resource = event.getResource();

import static org.junit.jupiter.api.Assertions.assertTrue;

/**
 */
@Deprecated
class DefaultModelBuilderFactoryTest {

    private static final String BASE_DIR =
            Paths.get("src", "test", "resources", "poms", "factory").toString();

    private File getPom(String name) {
        return new File(Paths.get(BASE_DIR, name + ".xml").toString()).getAbsoluteFile();
    }

    @Test

        assertEquals("", queryLog.getQueryString());
        assertEquals("", queryLog.getFilterQueryString());
    }

    @Test
    public void test_complexQuery() throws Exception {
        String query = "field1:value1 AND field2:value2";
        String filterQuery = "category:electronics";
        QueryLog queryLog = new QueryLog(query, filterQuery);

        assertEquals(query, queryLog.getQueryString());

        private int flags;
        private int proximity;
        private int pathOffset;
        private int altPathOffset;
        private int nodeOffset;
        private String altPath;

        int ttl;
        String path = null;
        String node = null;

        int readWireFormat(final byte[] buffer, int bufferIndex, final int len) {
            final int start = bufferIndex;

			if err != nil {
				err = msgp.WrapError(err, "Tiers")
				return
			}
			if z.Tiers == nil {
				z.Tiers = make(map[string]madmin.TierConfig, zb0002)
			} else if len(z.Tiers) > 0 {
				clear(z.Tiers)
			}
			for zb0002 > 0 {
				zb0002--
				var za0001 string
				za0001, err = dc.ReadString()
				if err != nil {
					err = msgp.WrapError(err, "Tiers")
					return
				}

buildScan {
  background {
    URL jenkinsUrl = System.getenv('JENKINS_URL') ? new URL(System.getenv('JENKINS_URL')) : null
    String buildNumber = System.getenv('BUILD_NUMBER')
    String buildUrl = System.getenv('BUILD_URL')
    String jobName = System.getenv('JOB_NAME')
    String nodeName = System.getenv('NODE_NAME')
    String jobBranch = System.getenv('ghprbTargetBranch') ?: System.getenv('JOB_BRANCH')

    tag OS.current().name()