Initialize the multiplexor with input and output streams.
14990
protected void init(MuxServer server, int channel)
        throws IOException
    {
        this.server = server;
        this.channel = channel;

        this.url = null;

        chunkLength = 0;
    }
1017852
public void initFromIterator(Iterator<IN> iterator) {
        this.pending = new ArrayDeque<>();
        isIteratorBased = true;
        //this._streams = kxReactiveStreams; needs sync init !!
        // in case iterator is blocking, need a dedicated thread ..
        Executor iteratorThread = new ThreadPoolExecutor(0, 1,
                                    10L, TimeUnit.MILLISECONDS,
                                    new LinkedBlockingQueue<Runnable>());
        producer = new Subscription() {
            boolean complete = false;
            @Override
            public void request(long outern) {
                iteratorThread.execute(() -> {
                    if (complete) {
                        return;
                    }
                    long n = outern;
                    try {
                        while (iterator.hasNext() && n-- > 0) {
                            self().onNext(iterator.next());
                        }
                        if (!iterator.hasNext()) {
                            complete = true;
                            self().onComplete();
                        }
                    } catch (Throwable t) {
                        self().onError(t);
                    }
                });
            }

            @Override
            public void cancel() {
            }
        };
        processor = in -> (OUT)in;
        onSubscribe(producer);
        Thread.currentThread().setName(Thread.currentThread()+" (rx async stream processor)");
    }
159852
private void initialize() {
        cfName = config.getTable();

        if (!ArrayUtils.isEmpty(config.getInputColumns())) {
            columns = StringUtils.join(config.getInputColumns(), ",");
        }

        partitioner = Utils.newTypeInstance(config.getPartitionerClassName(), IPartitioner.class);

        try {
            session = createConnection();

            retrieveKeys();
        } catch (Exception e) {
            throw new DeepIOException(e);
        }

        rowIterator = new RowIterator();
    }
684422
def initialize(self, num_of_paths=None, grid=None, seed=None):
        """"""
        super(StackedConsumer, self).initialize(grid, num_of_paths, seed)
        for c in self.consumers:
            c.initialize(grid, num_of_paths, seed)
        self.state = [c.state for c in self.consumers]
425879
public void initialize() throws IOException {
    // Create a pipe such that its one end is connected to the input stream used by
    // the uploader and the other end is the write channel used by the caller.
    PipedInputStream pipeSource = new PipedInputStream(pipeBufferSize);
    OutputStream pipeSink = new PipedOutputStream(pipeSource);
    pipeSinkChannel = Channels.newChannel(pipeSink);

    // Connect pipe-source to the stream used by uploader.
    InputStreamContent objectContentStream = new InputStreamContent(contentType, pipeSource);
    // Indicate that we do not know length of file in advance.
    objectContentStream.setLength(-1);
    objectContentStream.setCloseInputStream(false);

    T request = createRequest(objectContentStream);
    request.setDisableGZipContent(true);

    // Change chunk size from default value (10MB) to one that yields higher performance.
    clientRequestHelper.setChunkSize(request, uploadChunkSize);

    // Given that the two ends of the pipe must operate asynchronous relative
    // to each other, we need to start the upload operation on a separate thread.
    uploadOperation = threadPool.submit(new UploadOperation(request, pipeSource));

    isInitialized = true;
  }
649879
@SuppressWarnings("unchecked")
	public void initializeSerializers() {
		this.numChannels = this.outputGate.getNumChannels();
		this.serializers = new RecordSerializer[numChannels];
		for (int i = 0; i < this.numChannels; i++) {
			this.serializers[i] = new SpanningRecordSerializer<T>();
		}
	}
409424
@PostConstruct
    public synchronized void initialize() {
        final FwCoreDirection direction = assistCoreDirection();
        final ConcurrentAsyncExecutorProvider provider = direction.assistConcurrentAsyncExecutorProvider();
        defaultConcurrentAsyncOption = provider != null ? provider.provideDefaultOption() : null;
        if (defaultConcurrentAsyncOption == null) {
            defaultConcurrentAsyncOption = new ConcurrentAsyncOption();
        }
        primaryExecutorService = createDefaultPrimaryExecutorService(provider);
        secondaryExecutorService = createDefaultSecondaryExecutorService(provider);
        tertiaryExecutorService = createDefaultSecondaryExecutorService(provider);
        showBootLogging();
    }
1024055
def _initialize(cls):
    
    op_symbols = """
      + add radd pos
      - sub rsub neg
      * mul rmul
      / truediv rtruediv
      // floordiv rfloordiv
      % mod rmod
      ** pow rpow
      >> rshift rrshift
      << lshift rlshift
      ~ invert
      & and rand
      | or ror
      ^ xor rxor
      < lt
      <= le
      == eq
      != ne
      > gt
      >= ge
    """.strip().splitlines()
    if HAS_MATMUL:
      op_symbols.append("@ matmul rmatmul")
    for op_line in op_symbols:
      symbol, names = op_line.split(None, 1)
      for name in names.split():
        cls._insert(name, symbol)
79491
def init_pool(self):
        """"""

        # initialize the pool if needed
        if self.pool is None:
            if self.nproc > 1:
                self.pool = mp.Pool(processes=self.nproc)
            else:
                self.pool = None
        else:
            print('pool already initialized?')
329333
private synchronized void initOut() throws IOException
   {
      if (out == null)
      {
         OutputStream os = new IndexOutputStream(dir.createOutput(REDO_LOG));
         out = new BufferedWriter(new OutputStreamWriter(os));
      }
   }
481652
async def initialize(self) -> None:
            

            if self._socket_type == zmq.ROUTER:
                self._dealer_ident, _ = await self._sock.recv_multipart()
            elif self._socket_type == zmq.DEALER:
                await self._sock.send_multipart([b''])
            else:
                raise RuntimeError("initialize() not necessary for PAIR sockets")
86610
protected void initializeFilter( InputStream filterInput, OutputStream filterOutput)
    {
    try
      {
      // Create Transformer object.
      Source transform = getTransform();
      if( transform == null)
        {
        throw new IllegalStateException( "No XSLT transform specified");
        }
      TransformerFactory factory = TransformerFactory.newInstance();
      factory.setErrorListener( this);
      
      transformer_ = factory.newTransformer( transform);
      transformer_.setErrorListener( this);
      if( transformParams_ != null)
        {
        for( String paramName : transformParams_.keySet())
          {
          transformer_.setParameter( paramName, transformParams_.get( paramName));
          }
        }
      
      transformSource_ = new StreamSource( filterInput);
      transformResult_ = new StreamResult( filterOutput);
      }
    catch( Exception e)
      {
      throw new RuntimeException( "Can't initialize filter", e);
      } 
    }
1268123
@Override
    protected void initializeImpl()
    {
        super.initializeImpl();

        //init maps
        this.faxActionType2ReponseDataPathMap=new HashMap<FaxActionType,String>();
        this.statusString2FaxStatusMap=new HashMap<String,FaxJobStatus>();

        //populate maps
        this.populateFaxActionType2ReponseDataPathMappings();
        this.populateStatusString2FaxStatusMappings();

        //set error values
        Enum<?> configurationKey=this.getErrorDetectionPathPropertyKey();
        this.errorDetectionPath=this.getConfigurationValue(configurationKey);
        configurationKey=this.getErrorDetectionValuePropertyKey();
        this.errorDetectionValue=this.getConfigurationValue(configurationKey);
        configurationKey=this.getErrorMessagePathPropertyKey();
        this.errorMessagePath=this.getConfigurationValue(configurationKey);
    }
1332616
@Override
    protected void initializeImpl()
    {
        //create properties from configuration (all javax mail properties will be defined in the fax4j properties)
        this.mailConnectionProperties=new Properties();
        Map<String,String> configuration=this.factoryConfigurationHolder.getConfiguration();
        Iterator<Entry<String,String>> iterator=configuration.entrySet().iterator();
        Entry<String,String> entry=null;
        String key=null;
        String value=null;
        while(iterator.hasNext())
        {
            //get next entry
            entry=iterator.next();

            //get next key
            key=entry.getKey();
            if((key!=null)&&(key.indexOf("org.fax4j.")==-1))    //filter out fax4j properties
            {
                //get next value
                value=entry.getValue();
                
                //put in properties
                this.mailConnectionProperties.setProperty(key,value);
            }
        }
        
        //get user/password values
        this.userName=this.factoryConfigurationHolder.getConfigurationValue(FaxClientSpiConfigurationConstants.USER_NAME_PROPERTY_KEY);
        this.password=this.factoryConfigurationHolder.getConfigurationValue(FaxClientSpiConfigurationConstants.PASSWORD_PROPERTY_KEY);

        //get transport protocol
        this.transportProtocol=this.factoryConfigurationHolder.getConfigurationValue("mail.transport.protocol");
        if(this.transportProtocol==null)
        {
            this.transportProtocol="smtp";
        }

        //get transport host
        this.transportHost=this.factoryConfigurationHolder.getConfigurationValue("mail.smtp.host");
        
        //get transport port
        String transportPortStr=this.factoryConfigurationHolder.getConfigurationValue("mail.smtp.port");
        this.transportPort=-1;
        if(transportPortStr!=null)
        {
            this.transportPort=Integer.parseInt(transportPortStr);
        }
    }
1358698
public function init()
    {
        if ($this->isEnabled()) {
            $this->xmppclient = \PHPDaemon\Clients\XMPP\Pool::getInstance();
        }
    }
975963
function init() {
    network = [];
    netindex = new Int32Array(256);
    bias = new Int32Array(netsize);
    freq = new Int32Array(netsize);
    radpower = new Int32Array(netsize >> 3);

    var i, v;
    for (i = 0; i < netsize; i++) {
      v = (i << (netbiasshift + 8)) / netsize;
      network[i] = new Float64Array([v, v, v, 0]);
      //network[i] = [v, v, v, 0]
      freq[i] = intbias / netsize;
      bias[i] = 0;
    }
  }
720099
public static function init() {
		header("Transfer-Encoding: chunked");
		@apache_setenv('no-gzip', 1);
		@ini_set('zlib.output_compression', 0);
		@ini_set('implicit_flush', 1);
		for ($i = 0; $i < ob_get_level(); $i++)  ob_end_flush();
		ob_implicit_flush(1); flush();
		
		$pad = str_pad('',4096);
		echo dechex(strlen($pad))."\r\n";
		echo $pad;
		echo "\r\n";
	}