text:
package com.navercorp.pinpoint.profiler.context;

import com.navercorp.pinpoint.bootstrap.context.SpanEventRecorder;
import com.navercorp.pinpoint.bootstrap.context.SpanRecorder;
import com.navercorp.pinpoint.bootstrap.context.Trace;
import com.navercorp.pinpoint.profiler.context.active.ActiveTraceHandle;
import com.navercorp.pinpoint.profiler.context.id.TraceRoot;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;

import static org.mockito.Mockito.mock;

public class DisableTraceTest {
    @Test
    public void testGetScope() {
        Trace trace = newTrace();
        Trace childTrace = newChildTrace();
        Assertions.assertNull(trace.addScope("empty"));
        Assertions.assertNull(childTrace.addScope("empty"));
    }

    @Test
    public void testAddScope() {
        Trace trace = newTrace();
        Trace childTrace = newChildTrace();

        trace.addScope("aaa");
        childTrace.addScope("bbb");
        Assertions.assertNotNull(trace.getScope("aaa"));
        Assertions.assertNotNull(childTrace.getScope("bbb"));
    }

    @Test
    public void testSampled() {
        Trace trace = newTrace();
        Trace childTrace = newChildTrace();

        Assertions.assertFalse(trace.canSampled());
        Assertions.assertFalse(childTrace.canSampled());
    }

    @Test
    public void testSpanRecorder() {
        Trace trace = newTrace();
        Trace childTrace = newChildTrace();
        SpanRecorder spanRecorder = trace.getSpanRecorder();
        SpanRecorder childSpanRecorder = childTrace.getSpanRecorder();

        Assertions.assertNull(spanRecorder);
        Assertions.assertNull(childSpanRecorder);
    }

    @Test
    public void testCurrentSpanEventRecorder() {
        Trace trace = newTrace();
        Trace childTrace = newChildTrace();
        SpanEventRecorder spanEventRecorder = trace.currentSpanEventRecorder();
        SpanEventRecorder childSpanEventRecorder = childTrace.currentSpanEventRecorder();

        Assertions.assertNull(spanEventRecorder);
        Assertions.assertNull(childSpanEventRecorder);
    }

    private Trace newTrace() {
        ActiveTraceHandle activeTraceHandle = mock(ActiveTraceHandle.class);
        return new DisableTrace(1, 2, activeTraceHandle);
    }

    private Trace newChildTrace() {
        TraceRoot traceRoot = mock(TraceRoot.class);
        LocalAsyncId localAsyncId = mock(LocalAsyncId.class);

        return new DisableAsyncChildTrace(traceRoot, localAsyncId);
    }
}

redpajama_set_name: RedPajamaGithub


text:
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
	<parent>
		<groupId>org.sonatype.oss</groupId>
		<artifactId>oss-parent</artifactId>
		<version>7</version>
	</parent>

	<groupId>com.thihy</groupId>
	<modelVersion>4.0.0</modelVersion>
	<artifactId>elasticsearch-analysis-paoding</artifactId>
	<version>1.4.2.2-SNAPSHOT</version>
	<packaging>jar</packaging>

	<name>Paoding Analysis for ElasticSearch</name>
	<description>Paoding Analysis for ElasticSearch.</description>
	<url>https://github.com/thihy/elasticsearch-analysis-paoding</url>
	<inceptionYear>2014</inceptionYear>

	<licenses>
		<license>
			<name>The Apache Software License, Version 2.0</name>
			<url>http://www.apache.org/licenses/LICENSE-2.0.txt</url>
		</license>
	</licenses>

	<developers>
		<developer>
			<name>thihy</name>
			<email>my2003cat@gmail.com</email>
			<organization>thihy</organization>
			<organizationUrl>https://github.com/thihy</organizationUrl>
		</developer>
	</developers>
	<scm>
		<connection>scm:git:git@github.com:thihy/elasticsearch-analysis-paoding.git</connection>
		<developerConnection>scm:git:git@github.com:thihy/elasticsearch-analysis-paoding.git</developerConnection>
		<url>git@github.com:thihy/elasticsearch-analysis-paoding.git</url>
	</scm>
	<repositories>
		<repository>
			<id>Codehaus Snapshots</id>
			<url>http://repository.codehaus.org/</url>
		</repository>
	</repositories>

	<properties>
		<elasticsearch.version>1.4.2</elasticsearch.version>
		<lucene.maven.version>4.10.2</lucene.maven.version>
	</properties>

	<dependencies>
		<dependency>
			<groupId>org.hamcrest</groupId>
			<artifactId>hamcrest-all</artifactId>
			<version>1.3</version>
			<scope>test</scope>
		</dependency>
		<dependency>
			<groupId>com.carrotsearch.randomizedtesting</groupId>
			<artifactId>randomizedtesting-runner</artifactId>
			<version>2.1.10</version>
			<scope>test</scope>
		</dependency>
		<dependency>
			<groupId>org.apache.lucene</groupId>
			<artifactId>lucene-test-framework</artifactId>
			<version>${lucene.maven.version}</version>
			<scope>test</scope>
		</dependency>
		<dependency>
			<groupId>org.apache.httpcomponents</groupId>
			<artifactId>httpclient</artifactId>
			<version>4.3.5</version>
			<scope>test</scope>
		</dependency>
		<dependency>
			<groupId>org.elasticsearch</groupId>
			<artifactId>elasticsearch</artifactId>
			<version>${elasticsearch.version}</version>
			<classifier>tests</classifier>
			<scope>test</scope>
		</dependency>
		<dependency>
			<groupId>org.elasticsearch</groupId>
			<artifactId>elasticsearch</artifactId>
			<version>${elasticsearch.version}</version>
			<scope>provided</scope>
		</dependency>
		<dependency>
			<groupId>com.google.guava</groupId>
			<artifactId>guava</artifactId>
			<version>18.0</version>
		</dependency>
	</dependencies>

	<build>
		<plugins>
			<plugin>
				<groupId>org.apache.maven.plugins</groupId>
				<artifactId>maven-compiler-plugin</artifactId>
				<version>2.3.2</version>
				<configuration>
					<source>1.7</source>
					<target>1.7</target>
				</configuration>
			</plugin>
			<plugin>
				<groupId>org.apache.maven.plugins</groupId>
				<artifactId>maven-source-plugin</artifactId>
				<version>2.1.2</version>
				<executions>
					<execution>
						<id>attach-sources</id>
						<goals>
							<goal>jar</goal>
						</goals>
					</execution>
				</executions>
			</plugin>
			<plugin>
				<artifactId>maven-assembly-plugin</artifactId>
				<version>2.3</version>
				<configuration>
					<appendAssemblyId>false</appendAssemblyId>
					<outputDirectory>${project.build.directory}/releases/</outputDirectory>
					<descriptors>
						<descriptor>${basedir}/src/main/assemblies/plugin.xml</descriptor>
					</descriptors>
				</configuration>
				<executions>
					<execution>
						<phase>package</phase>
						<goals>
							<goal>single</goal>
						</goals>
					</execution>
				</executions>
			</plugin>
		</plugins>
	</build>
</project>


text:
import {Transaction} from '../utilities/models';
import {SharedTile} from './shared';

const TransactionSummary = ({transaction}: {transaction: Transaction}) => {
  const {size, fee} = transaction;
  return (
    <>
      <SharedTile title='Size' description={`${size} (bytes)`} />
      {fee >= 0 && size ? (
        <SharedTile title='Fee Rate' description={`${(fee / size).toFixed(2)} sats/bytes`} />
      ) : null}
    </>
  );
};

export default TransactionSummary;


text:
#ifndef TORRENT_DISABLE_DHT

#ifndef TORRENT_DHT_TRACKER
#define TORRENT_DHT_TRACKER

#include <fstream>
#include <set>
#include <numeric>
#include <boost/bind.hpp>
#include <boost/ref.hpp>
#include <boost/smart_ptr/enable_shared_from_this.hpp>

#include "libtorrent/kademlia/node.hpp"
#include "libtorrent/kademlia/node_id.hpp"
#include "libtorrent/kademlia/traversal_algorithm.hpp"
#include "libtorrent/kademlia/dos_blocker.hpp"

#include "libtorrent/session_settings.hpp"
#include "libtorrent/udp_socket.hpp"
#include "libtorrent/socket.hpp"
#include "libtorrent/thread.hpp"
#include "libtorrent/deadline_timer.hpp"

namespace libtorrent
{
	namespace aux { struct session_impl; }
	struct counters;
#ifndef TORRENT_NO_DEPRECATE
	struct session_status;
#endif
}

namespace libtorrent { namespace dht
{

#ifdef TORRENT_DHT_VERBOSE_LOGGING
	TORRENT_DECLARE_LOG(dht_tracker);
#endif

	struct dht_tracker;

	struct dht_tracker
		: udp_socket_interface
		, udp_socket_observer
		, boost::enable_shared_from_this<dht_tracker>
	{
		dht_tracker(libtorrent::aux::session_impl& ses, rate_limited_udp_socket& sock
			, dht_settings const& settings, counters& cnt, entry const* state = 0);
		virtual ~dht_tracker();

		void start(entry const& bootstrap
			, find_data::nodes_callback const& f);
		void stop();

		void add_node(udp::endpoint node);
		void add_node(std::pair<std::string, int> const& node);
		void add_router_node(udp::endpoint const& node);

		entry state() const;

		enum flags_t { flag_seed = 1, flag_implied_port = 2 };
		void announce(sha1_hash const& ih, int listen_port, int flags
			, boost::function<void(std::vector<tcp::endpoint> const&)> f);

		void get_item(sha1_hash const& target
			, boost::function<void(item const&)> cb);

		// key is a 32-byte binary string, the public key to look up.
		// the salt is optional
		void get_item(char const* key
			, boost::function<void(item const&)> cb
			, std::string salt = std::string());

		void put_item(entry data
			, boost::function<void()> cb);

		void put_item(char const* key
			, boost::function<void(item&)> cb, std::string salt = std::string());

#ifndef TORRENT_NO_DEPRECATE
		void dht_status(session_status& s);
#endif
		void dht_status(std::vector<dht_routing_bucket>& table
			, std::vector<dht_lookup>& requests);

		// translate bittorrent kademlia message into the generic kademlia message
		// used by the library
		virtual bool incoming_packet(error_code const& ec
			, udp::endpoint const&, char const* buf, int size);

	private:

		boost::shared_ptr<dht_tracker> self()
		{ return shared_from_this(); }

		void on_name_lookup(error_code const& e
			, udp::resolver::iterator host);
		void on_router_name_lookup(error_code const& e
			, udp::resolver::iterator host);
		void connection_timeout(error_code const& e);
		void refresh_timeout(error_code const& e);
		void tick(error_code const& e);

		// implements udp_socket_interface
		virtual bool has_quota();
		virtual bool send_packet(libtorrent::entry& e, udp::endpoint const& addr
			, int send_flags);

		// this is the bdecode_node DHT messages are parsed into. It's a member
		// in order to avoid having to deallocate and re-allocate it for every
		// message.
		bdecode_node m_msg;

		counters& m_counters;
		node_impl m_dht;
		rate_limited_udp_socket& m_sock;

		std::vector<char> m_send_buf;
		dos_blocker m_blocker;

		time_point m_last_new_key;
		deadline_timer m_timer;
		deadline_timer m_connection_timer;
		deadline_timer m_refresh_timer;
		dht_settings const& m_settings;
		int m_refresh_bucket;

		bool m_abort;

		// used to resolve hostnames for nodes
		udp::resolver m_host_resolver;
	};
}}

#endif
#endif


text:
<TITLE>Review for Snatch. (2000)</TITLE>
<LINK REL="STYLESHEET" TYPE="text/css" HREF="/ramr.css">

Snatch. (2000)

reviewed by
Harvey S. Karten

SNATCH

 Reviewed by Harvey Karten
 Screen Gems
 Director: Guy Ritchie
 Writer:  Guy Ritchie
 Cast: Benicio Del Toro, Dennis Farina, Mike Reid, Rade
Serbedzija, Robbie Gee, Lennie James, Ade, Jason Statham,
Stephen Graham, Alan Ford, Brad Pitt

  I've heard said that young people don't give much of a fig
for stories anymore. What they want to see on the screen is
special effects along with their explosions and car crashes--
which accounts for box office takes  for "The Cell," "Vertical
Limit," and "Proof of Life."  If they can't get special effects or
explosions, then give the principal target audience lots of
visuals, actions galore to keep their minds distracted from the
fact that the movie has no plot worth thinking about.
"Snatch," written and directed by Guy Ritchie--who gave us
"Lock, Stock and Two Smoking Barrels" but does not
consider this a sequel--is mayhem posing as hip; motion
aspiring to chic.  While this bit of convuluted,
disconnected mayhem may simply be the sort of thing I just
don't "get," I suspect that "Snatch" is the picture that will be
praised by people who are eager to patronize the lovers of
story lines--the folks they consider plain too old-fashioned to
go for postmodern gibberish.

   While we may be tempted to think that the title is a double
entendre, "Snatch" seems to refer exclusively to the aim of
some London and NY underworld characters to seize an 83-
carat diamond, but this is no "Topkapi" by a long shot.  The
diamond caper takes a backseat to some almost
incomprehensible activities executed by a cast doing
uninteresting things with the one exception of a pit bull which
is instrumental to the yarn--and that dog doesn't even get a
credit.

   The commotion begins when a quartet of diamond bandits
disguised as Hasidim including Franky Four Fingers (Benicio
Del Toro) rip off a wholesale jeweler to deliver the 83 carat
diamond to Franky's employer, Avi (Dennis Farina).  Franky,
a compulsive gambler, bets with the Russian Boris The Blade
(Rade Serbedjija) on an illegal boxing bout, unaware that he
is being set up for a robbery at the hands of Vinny (Robbie
Gee), Sol (Lennie James), and Tyrone (Ade).  (Ade, the
getaway driver, is so fat that he can barely get out of the
getaway car...that's the level of humor you'll find in various
parts of the movie.)  Turkish (Jason Statham) hooks up with
top criminal and pig farm owner (the pigs are used to eat
bodies, thereby disposing of evidence) Brick Top (Alan Ford)
to fix a fight, but Mikey O'Neil (Brad Pitt), an Irish gypsy who
speaks an almost impenetrable language, refuses to take a
fall and knocks out all opponents.

   The one catchy visual in this picture can be missed if you
blink and will remind cineastes of a similar run-through of
sorts in "Requiem for a Dream."  Avi, the only attractive and
interesting human being in the movie, catches a Concorde to
London: Ritchie shows the entire booking, the flight and the
movement through British passport control in four seconds.

  Though the violence is largely an illusion, instances of solid
editing by Jon Harris, the suggestion is as brutal as that
found in "Fight Club," including the mostly off-screen poking
of a caged pit bull and the sending of a couple of killer dogs
after a frightened rabbit for sport.  The film is about a
succession of double crosses, indicating that there really is
no honesty among thieves and rascals, but to get back to my
theory, I think the film will be used by the chic set to look
down on fuddy-duddies who prefer movies to have a point.

Rated R.  Running time: 105 minutes.  (C) 2000 by
Harvey Karten, film_critic@compuserve.com

The review above was posted to the
rec.arts.movies.reviews newsgroup (de.rec.film.kritiken for German reviews).

The Internet Movie Database accepts no responsibility for the contents of the
review and has no editorial control. Unless stated otherwise, the copyright
belongs to the author.

Please direct comments/criticisms of the review to relevant newsgroups.

Broken URLs inthe reviews are the responsibility of the author.

The formatting of the review is likely to differ from the original due
to ASCII to HTML conversion.

Related links: index of all rec.arts.movies.reviews reviews


text:
(function () {
  'use strict';

  angular
    .module('horarios')
    .factory('HorariosService', HorariosService);

  HorariosService.$inject = ['$resource'];

  function HorariosService($resource) {
    return $resource('api/horarios/:horarioId', {
      horarioId: '@_id'
    }, {
      update: {
        method: 'PUT'
      }
    });
  }
})();


text:
import data_io
import pickle
import numpy as np

def main():
    print("Loading the classifier")
    classifier = data_io.load_model()

    print("Making predictions")
    valid = data_io.get_valid_df()
    predictions = classifier.predict(valid)
    predictions = np.rint(predictions) # Round predictions to nearest integer.

    print("Writing predictions to file")
    data_io.write_submission(predictions)

if __name__=="__main__":
    main()


text:
// -----------------------------------------------------------------------
// <copyright file="DummyInterpreter.cs">
// Copyright (c) 2015 Andrew Zavgorodniy. All rights reserved.
// </copyright>
// -----------------------------------------------------------------------

namespace MyStudio.Services
{
    using System.Diagnostics;

    public class DummyInterpreter: IInterpreter
    {
        public void ExecuteScript(string script)
        {
            Debug.Write("It works");
        }
    }
}


text:
<?php
namespace UNL\UCBCN\Manager;

use UNL\UCBCN\User;
use UNL\UCBCN\Calendar;
use UNL\UCBCN\Event;
use UNL\UCBCN\Event\Occurrence;
use UNL\UCBCN\Event\RecurringDate;
use UNL\UCBCN\Permission;

class DeleteRecurrence extends PostHandler
{
    public $options = array();
    public $calendar;
    public $event;
    public $event_datetime;
    public $recurrence;

    public function __construct($options = array())
    {
        $this->options = $options + $this->options;
        $this->calendar = Calendar::getByShortName($this->options['calendar_shortname']);
        if ($this->calendar === FALSE) {
            throw new \Exception("That calendar could not be found.", 404);
        }

        $user = Auth::getCurrentUser();
        if (!$user->hasPermission(Permission::EVENT_EDIT_ID, $this->calendar->id)) {
            throw new \Exception("You do not have permission to edit events on this calendar.", 403);
        }

        $this->event = Event::getByID($this->options['event_id']);
        if ($this->event === FALSE) {
            throw new \Exception("That event could not be found.", 404);
        }

        $this->event_datetime = Occurrence::getByID($this->options['event_datetime_id']);

        if ($this->event_datetime === FALSE) {
            throw new \Exception("That datetime could not be found.", 404);
        }

        if (!$this->event_datetime->isRecurring()) {
            throw new \Exception("That datetime is not recurring.", 400);
        }

        $this->recurrence = $this->event_datetime->getRecurrence($this->options['recurrence_id']);

        if ($this->recurrence === FALSE) {
            throw new \Exception("That recurrence does not exist.", 404);
        }
    }

    public function handlePost(array $get, array $post, array $files)
    {
        if (!isset($post['event_datetime_id'])) {
            throw new \Exception("The event_datetime_id must be set in the post data", 400);
        }

        if ($post['event_datetime_id'] != $this->event_datetime->id) {
            throw new \Exception("The event_datetime_id in the post data must match the event_datetime_id in the URL", 400);
        }

        if (!isset($post['recurrence_id'])) {
            throw new \Exception("The recurrence_id must be set in the post data", 400);
        }

        if ($post['recurrence_id'] != $this->recurrence->recurrence_id) {
            throw new \Exception("The recurrence_id in the post data must match the recurrence_id in the URL", 400);
        }

        $this->recurrence->unlink();

        $this->flashNotice(NOTICE_LEVEL_SUCCESS, 'Recurrence Deleted', 'A recurrence of a recurring location/date/time from this event has been removed.');
        // Redirect to the event edit page
        return $this->event->getEditURL($this->calendar);
    }
}


text:
package com.android.reverse.collecter;

import java.io.IOException;

import android.os.Debug;

public class HeapDump {

	public static void dumpHeap(String filename) {
		try {
			Debug.dumpHprofData(filename);
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

}


text:
KAFKA_BIN ?= /usr/local/Cellar/kafka/0.11.0.1/bin

start-k: start-z
	${KAFKA_BIN}/kafka-server-start /usr/local/etc/kafka/server.properties &

stop-k:
	${KAFKA_BIN}/kafka-server-stop /usr/local/etc/kafka/server.properties

start-z:
	zkServer start

stop-z:
	zkServer stop

all-in-one-tested:
	mvn assembly:assembly

all-in-one:
	mvn assembly:assembly -DskipTests

deploy-wfm:
	storm jar target/WorkflowManager-1.0-SNAPSHOT-jar-with-dependencies.jar \
        org.openkilda.wfm.topology.event.OFEventWFMTopology \
        --name=wfm ${config}

kill-wfm:
	storm kill wfm >/dev/null 2>&1

deploy-flow:
	storm jar target/WorkflowManager-1.0-SNAPSHOT-jar-with-dependencies.jar \
        org.openkilda.wfm.topology.flow.FlowTopology \
        --name=flow ${config}

kill-flow:
	storm kill flow >/dev/null 2>&1

deploy-stats:
	storm jar target/WorkflowManager-1.0-SNAPSHOT-jar-with-dependencies.jar \
        org.openkilda.wfm.topology.stats.StatsTopology \
        --name=stats ${config}

kill-stats:
	storm kill stats >/dev/null 2>&1

deploy-cache:
	storm jar target/WorkflowManager-1.0-SNAPSHOT-jar-with-dependencies.jar \
        org.openkilda.wfm.topology.cache.CacheTopology \
        --name=cache ${config}

kill-cache:
	storm kill cache >/dev/null 2>&1

deploy-islstats:
	storm jar target/WorkflowManager-1.0-SNAPSHOT-jar-with-dependencies.jar \
		org.openkilda.wfm.topology.islstats.IslStatsTopology \
		--name=islstats ${config}

kill-islstats:
	storm kill islstats >/dev/null 2>&1

deploy-opentsdb:
	storm jar target/WorkflowManager-1.0-SNAPSHOT-jar-with-dependencies.jar \
		org.openkilda.wfm.topology.opentsdb.OpenTSDBTopology \
		--name=opentsdb ${config}

kill-opentsdb:
	storm kill opentsdb >/dev/null 2>&1

deploy-portstate:
	storm jar target/WorkflowManager-1.0-SNAPSHOT-jar-with-dependencies.jar \
		org.openkilda.wfm.topology.portstate.PortStateTopology \
		--name=portstate ${config}

kill-portstate:
	storm kill portstate >/dev/null 2>&1


text:
<?php

use Illuminate\Database\Seeder;

class TaskTableSeeder extends Seeder
{
    public function run()
    {
        DB::table('tasks')->delete();
    }
}


text: My personal study based on the RXJava Essentials Book


text:
package impl.com.calendarfx.view.print;

import com.calendarfx.view.Messages;
import com.calendarfx.view.print.TimeRangeView;
import javafx.beans.binding.Bindings;
import javafx.geometry.HPos;
import javafx.scene.control.Label;
import javafx.scene.control.SkinBase;
import javafx.scene.layout.ColumnConstraints;
import javafx.scene.layout.GridPane;

public class TimeRangeViewSkin extends SkinBase<TimeRangeView> {

    public TimeRangeViewSkin(TimeRangeView control) {
        super(control);

        Label overviewLabel = new Label();
        overviewLabel.textProperty()
                .bind(Bindings
                        .createStringBinding(
                                () -> control.getUnitsToPrint() == 0 ? ""
                                        : Messages
                                        .getString("TimeRangeViewSkin.PERIOD_LABEL", control.getUnitsToPrint(),
                                                Messages.getString(
                                                        control.getViewType().getPluralChronoMessageKey())),
                                control.unitsToPrintProperty(), control.viewTypeProperty()));

        GridPane gridPane = new GridPane();
        gridPane.getStyleClass().add("container");
        gridPane.add(new Label(Messages.getString("TimeRangeViewSkin.START_LABEL")), 0, 0);
        gridPane.add(control.getStartField(), 1, 0);
        gridPane.add(new Label(Messages.getString("TimeRangeViewSkin.END_LABEL")), 0, 1);
        gridPane.add(control.getEndField(), 1, 1);
        gridPane.add(overviewLabel, 1, 2);

        ColumnConstraints col1 = new ColumnConstraints();
        ColumnConstraints col2 = new ColumnConstraints();
        gridPane.getColumnConstraints().addAll(col1, col2);

        GridPane.setHalignment(control.getStartField(), HPos.LEFT);
        GridPane.setHalignment(control.getEndField(), HPos.LEFT);

        GridPane.setFillWidth(control.getStartField(), true);
        GridPane.setFillWidth(control.getEndField(), true);

        getChildren().add(gridPane);
    }

}


text:
%--------------------------------------------------------------------------
% Author: Montiel Abello - montiel.abello@gmail.com - 23/05/17
% Contributors:
%--------------------------------------------------------------------------

classdef GeometricPrimitive < ArrayGetSet & matlab.mixin.Heterogeneous
    %GEOMETRICPRIMITIVE is a base class for representing geometrices
    %   GeometricPrimitive class has no properties or methods itself. It
    %   inherits from matlab.mixin.Heterogeneous which allows different
    %   geometric primitive subclasses to be stored in object arrays
    %   Direct subclasses of GeometricPrimitive are:
    %       -GP_Point
    %       -GP_Poses
    %   *Note: useful subclasses could be Screw,Twist,Wrench or plane,
    %   ellipse...

    %% 1. Properties

    %% 2. Methods

end


text:
#include <vlc/vlc.h>
#include <vlc_common.h>

#include <jni.h>

#include "utils.h"

#define LOG_TAG "VLC/JNI/Equalizer"
#include "log.h"

/**
 * return band list as float[]
 */
jfloatArray Java_org_videolan_libvlc_LibVLC_getBands(JNIEnv *env, jobject thiz)
{
    unsigned count = libvlc_audio_equalizer_get_band_count();
    jfloatArray bands = (*env)->NewFloatArray(env, count);

    for (unsigned i = 0; i < count; ++i)
    {
        jfloat band = libvlc_audio_equalizer_get_band_frequency(i);
        (*env)->SetFloatArrayRegion(env, bands, i, 1, &band);
    }
    return bands;
}

/**
 * return preset list as String[]
 */
jobjectArray Java_org_videolan_libvlc_LibVLC_getPresets(JNIEnv *env, jobject thiz)
{
    unsigned count = libvlc_audio_equalizer_get_preset_count();
    jclass stringClass = (*env)->FindClass(env, "java/lang/String");
    jobjectArray presets = (*env)->NewObjectArray(env, count, stringClass, NULL);

    for (unsigned i = 0; i < count; ++i)
    {
        const char *name = libvlc_audio_equalizer_get_preset_name(i);
        jstring jname = (*env)->NewStringUTF(env, name);
        (*env)->SetObjectArrayElement(env, presets, i, jname);
    }
    return presets;
}

/**
 * return preset n° <index> as float[] (first element is preamp, then bands)
 */
jfloatArray Java_org_videolan_libvlc_LibVLC_getPreset(JNIEnv *env, jobject thiz, jint index)
{
    unsigned count = libvlc_audio_equalizer_get_band_count();
    jfloatArray array = (*env)->NewFloatArray(env, count + 1);
    libvlc_equalizer_t *p_equalizer = libvlc_audio_equalizer_new_from_preset(index);
    if (p_equalizer != NULL)
    {
        jfloat preamp = libvlc_audio_equalizer_get_preamp(p_equalizer);
        (*env)->SetFloatArrayRegion(env, array, 0, 1, &preamp);

        for (unsigned i = 0; i < count; ++i)
        {
            jfloat band = libvlc_audio_equalizer_get_amp_at_index(p_equalizer, i);
            (*env)->SetFloatArrayRegion(env, array, i + 1, 1, &band);
        }
        libvlc_audio_equalizer_release(p_equalizer);
    }
    return array;
}

/**
 * apply equalizer settings (param bands is float[] (first element is preamp, then bands))
 */
//"--audio-filter=equalizer", "--equalizer-bands=-3.5 -4.5 -1 0 0 5 8 8 8 8",
jint Java_org_videolan_libvlc_LibVLC_setNativeEqualizer(JNIEnv *env, jobject thiz, jlong media_player, jfloatArray bands)
{
    jint res = -1;
    libvlc_media_player_t *mp = (libvlc_media_player_t*)(intptr_t)media_player;
    if (!mp)
        return res;

    if (bands == NULL)
        return libvlc_media_player_set_equalizer(mp, NULL);

    jfloat *cbands = (*env)->GetFloatArrayElements(env, bands, NULL);
    if (cbands == NULL)
        return res;

    jsize input_count = (*env)->GetArrayLength(env, bands);
    unsigned band_count = libvlc_audio_equalizer_get_band_count();
    if (input_count == band_count+1) // first item is preamp
    {
        libvlc_equalizer_t *p_equalizer = libvlc_audio_equalizer_new();
        libvlc_audio_equalizer_set_preamp(p_equalizer, cbands[0]);
        for (unsigned i = 0; i < band_count; ++i)
        {
            libvlc_audio_equalizer_set_amp_at_index(p_equalizer, cbands[i+1], i);
        }
        res = libvlc_media_player_set_equalizer(mp, p_equalizer);
        libvlc_audio_equalizer_release(p_equalizer);
    }
    return res;
}


text:
<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:orientation="vertical"
    >

    <View
        android:layout_width="match_parent"
        android:layout_height="1dp"
        android:background="@color/line_bg"
        android:layout_marginTop="20dp"/>
    <TextView
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:id="@+id/tv_friend"
        android:drawableLeft="@mipmap/icon_explore_friends"
        android:drawablePadding="15dp"
        android:paddingTop="10dp"
        android:paddingBottom="10dp"
        android:background="@drawable/item_selector"
        android:clickable="true"
        android:text="@string/friends"
        android:gravity="center_vertical"/>
    <View
        android:layout_width="match_parent"
        android:layout_height="1dp"
        android:background="@color/line_bg"/>

    <View
        android:layout_width="match_parent"
        android:layout_height="1dp"
        android:background="@color/line_bg"
        android:layout_marginTop="20dp"/>

    <TextView
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:id="@+id/tv_finduser"
        android:drawableLeft="@mipmap/icon_explore_finduser"
        android:drawablePadding="15dp"
        android:paddingTop="10dp"
        android:paddingBottom="10dp"
        android:background="@drawable/item_selector"
        android:clickable="true"
        android:text="@string/finduser"
        android:gravity="center_vertical"/>
    <View
        android:layout_width="match_parent"
        android:layout_height="1dp"
        android:background="@color/line_bg"
        />
    <TextView
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:id="@+id/tv_event"
        android:drawableLeft="@mipmap/icon_explore_event"
        android:drawablePadding="15dp"
        android:paddingTop="10dp"
        android:background="@drawable/item_selector"
        android:clickable="true"
        android:paddingBottom="10dp"
        android:text="@string/event"
        android:gravity="center_vertical"/>
    <View
        android:layout_width="match_parent"
        android:layout_height="1dp"
        android:background="@color/line_bg"
        />

    <View
        android:layout_width="match_parent"
        android:layout_height="1dp"
        android:background="@color/line_bg"
        android:layout_marginTop="20dp"
        />
    <TextView
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:id="@+id/tv_scane"
        android:drawableLeft="@mipmap/icon_explore_scan"
        android:drawablePadding="15dp"
        android:paddingTop="10dp"
        android:paddingBottom="10dp"
        android:background="@drawable/item_selector"
        android:clickable="true"
        android:text="@string/scan"
        android:gravity="center_vertical"/>
    <View
        android:layout_width="match_parent"
        android:layout_height="1dp"
        android:background="@color/line_bg"
        />
    <TextView
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:id="@+id/tv_shake"
        android:drawableLeft="@mipmap/icon_explore_shake"
        android:drawablePadding="15dp"
        android:paddingTop="10dp"
        android:paddingBottom="10dp"
        android:text="@string/shake"
        android:background="@drawable/item_selector"
        android:clickable="true"
        android:gravity="center_vertical"/>
    <View
        android:layout_width="match_parent"
        android:layout_height="1dp"
        android:background="@color/line_bg"
        />

</LinearLayout>


text:
layout: category
title: Bocks
permalink: '/categories/bock'
---

## Blog Posts

{% for post in site.categories['bock'] %}
  * {{ post.title }}
{% endfor %}


text:
using Microsoft.Owin;
using Owin;

[assembly: OwinStartup(typeof(DeviceOrientation.Startup))]

namespace DeviceOrientation
{
    public class Startup
    {
        public void Configuration(IAppBuilder app)
        {
            // Any connection or hub wire up and configuration should go here
            app.MapSignalR();
        }
    }
}


text:
<!DOCTYPE html>

    <meta charset="utf-8">
    <meta name="viewport" content="width=device-width, initial-scale=1, shrink-to-fit=no">
    <meta name="description" content="">
    <meta name="author" content="">

    <title>Navee's Landing Inn | Trying to build the future of online Comics!</title>

    <link href="vendor/bootstrap/css/bootstrap.min.css" rel="stylesheet">

    <link rel="stylesheet" href="vendor/font-awesome/css/font-awesome.min.css">
    <link rel="stylesheet" href="vendor/simple-line-icons/css/simple-line-icons.css">
    <link href="https://fonts.googleapis.com/css?family=Lato" rel="stylesheet">
    <link href="https://fonts.googleapis.com/css?family=Catamaran:100,200,300,400,500,600,700,800,900" rel="stylesheet">
    <link href="https://fonts.googleapis.com/css?family=Muli" rel="stylesheet">

    <link rel="stylesheet" href="device-mockups/device-mockups.min.css">

    <link href="css/new-age.min.css" rel="stylesheet">

   	  LOG IN

ENTER A NEW WORLD

The ultimate manga reading platform

              START READING

What's on Navee ?

Every title

Over 10,000 chapters from all the titles you can think of. Yes, even that secret manga you could never find.

Every chapter

From the first volumes to the latest chapters just published in Japan... Navee has them all !

Every category

Comedies, thrilles, sci-fi, romance... No, those are not only categories for TV series but for Manga as well. Silver lining? There is one for everyone !

Reading manga has never been easier.

                    <video width="100%" height="100%" autoplay loop>
					  <source src="img/TEST-01.mp4" type="video/mp4">
					  Your browser does not support the video tag.
					</video>

Choose

Know already what you want to read? Just search and start reading.

                    Still looking for inspiration? Tell us what you like and Navee will suggest some titles.

Experience

Dive deeper into the story by not just reading it but listening to it. Thanks to our Immersive Reading® follow the voice of our narrators and find an whole new depth to reading. What's more? No ads, HD quality, and the latest from the authors. Sit back and enjoy.

Engage

Access reviews, the best of the week, and various interviews with authors, editors and the wider community. Talk with others fans about your favorite manga and don't miss the latest releases thanks to personalized notifications.

One account.

			  Read anywhere, anytime. On any device.

			  Download your favorite titles to enjoy them offline. Also the audio.

Let's get down to manga.

Navee Free

FREE
 / month

A chapter per manga per week

Personalized advices

Read offline

Access to the community

HD Quality

Ad free

Immersive reading

Editorial content

            Get Free

Navee Premium

$6.99
 / month

Unlimited Reading

Personalized advices

Read offline

Access to the community

HD Quality

Ad free

Immersive reading

Editorial content

            Get Premium

You can't judge a manga by its cover !

© Copyright - Navee - 2017


text:
from transformers import BertTokenizer, EncoderDecoderModel, Seq2SeqTrainer, Seq2SeqTrainingArguments
from transformers.file_utils import is_datasets_available
from transformers.testing_utils import TestCasePlus, require_datasets, require_torch, slow

if is_datasets_available():
    import datasets

class Seq2seqTrainerTester(TestCasePlus):
    @slow
    @require_torch
    @require_datasets
    def test_finetune_bert2bert(self):
        bert2bert = EncoderDecoderModel.from_encoder_decoder_pretrained("prajjwal1/bert-tiny", "prajjwal1/bert-tiny")
        tokenizer = BertTokenizer.from_pretrained("bert-base-uncased")

        bert2bert.config.vocab_size = bert2bert.config.encoder.vocab_size
        bert2bert.config.eos_token_id = tokenizer.sep_token_id
        bert2bert.config.decoder_start_token_id = tokenizer.cls_token_id
        bert2bert.config.max_length = 128

        train_dataset = datasets.load_dataset("cnn_dailymail", "3.0.0", split="train[:1%]")
        val_dataset = datasets.load_dataset("cnn_dailymail", "3.0.0", split="validation[:1%]")

        train_dataset = train_dataset.select(range(32))
        val_dataset = val_dataset.select(range(16))

        batch_size = 4

        def _map_to_encoder_decoder_inputs(batch):
            # Tokenizer will automatically set [BOS] <text> [EOS]
            inputs = tokenizer(batch["article"], padding="max_length", truncation=True, max_length=512)
            outputs = tokenizer(batch["highlights"], padding="max_length", truncation=True, max_length=128)
            batch["input_ids"] = inputs.input_ids
            batch["attention_mask"] = inputs.attention_mask

            batch["decoder_input_ids"] = outputs.input_ids
            batch["labels"] = outputs.input_ids.copy()
            batch["labels"] = [
                [-100 if token == tokenizer.pad_token_id else token for token in labels] for labels in batch["labels"]
            ]
            batch["decoder_attention_mask"] = outputs.attention_mask

            assert all([len(x) == 512 for x in inputs.input_ids])
            assert all([len(x) == 128 for x in outputs.input_ids])

            return batch

        def _compute_metrics(pred):
            labels_ids = pred.label_ids
            pred_ids = pred.predictions

            # all unnecessary tokens are removed
            pred_str = tokenizer.batch_decode(pred_ids, skip_special_tokens=True)
            label_str = tokenizer.batch_decode(labels_ids, skip_special_tokens=True)

            accuracy = sum([int(pred_str[i] == label_str[i]) for i in range(len(pred_str))]) / len(pred_str)

            return {"accuracy": accuracy}

        # map train dataset
        train_dataset = train_dataset.map(
            _map_to_encoder_decoder_inputs,
            batched=True,
            batch_size=batch_size,
            remove_columns=["article", "highlights"],
        )
        train_dataset.set_format(
            type="torch",
            columns=["input_ids", "attention_mask", "decoder_input_ids", "decoder_attention_mask", "labels"],
        )

        # same for validation dataset
        val_dataset = val_dataset.map(
            _map_to_encoder_decoder_inputs,
            batched=True,
            batch_size=batch_size,
            remove_columns=["article", "highlights"],
        )
        val_dataset.set_format(
            type="torch",
            columns=["input_ids", "attention_mask", "decoder_input_ids", "decoder_attention_mask", "labels"],
        )

        output_dir = self.get_auto_remove_tmp_dir()

        training_args = Seq2SeqTrainingArguments(
            output_dir=output_dir,
            per_device_train_batch_size=batch_size,
            per_device_eval_batch_size=batch_size,
            predict_with_generate=True,
            evaluation_strategy="steps",
            do_train=True,
            do_eval=True,
            warmup_steps=0,
            eval_steps=2,
            logging_steps=2,
        )

        # instantiate trainer
        trainer = Seq2SeqTrainer(
            model=bert2bert,
            args=training_args,
            compute_metrics=_compute_metrics,
            train_dataset=train_dataset,
            eval_dataset=val_dataset,
            tokenizer=tokenizer,
        )

        # start training
        trainer.train()


text:
<?php
	namespace Attw\DB\Exception;

	use \RuntimeException;

	class StatementException extends RuntimeException{}


text:
module Capistrano
  # Spy
  module Spy
    # gem version
    VERSION = '0.1.5'
  end
end


text:
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">

<title>R.id</title>
<meta name="date" content="2014-11-10">
<link rel="stylesheet" type="text/css" href="../../../stylesheet.css" title="Style">

JavaScript is disabled on your browser.

Skip navigation links

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

Prev Class

Next Class

Frames

No Frames

All Classes

Summary:

Nested |

Field |

Constr |

Method

Detail:

Field |

Constr |

Method

cs.ualberta.octoaskt12

Class R.id

java.lang.Object

cs.ualberta.octoaskt12.R.id

Enclosing class:

R

public static final class R.id
extends java.lang.Object

Field Summary

Fields

Modifier and Type
Field and Description

static int
action_settings

static int
add_answer_button

static int
answer_upvote_caption

static int
answerBodyText

static int
cancelAnswerButton

static int
cancelQuestionButton

static int
cancelReplyButton

static int
container

static int
detail_answer_header

static int
detail_answer_replies

static int
detail_answer_replies_add

static int
detail_question_body

static int
detail_question_header

static int
detail_question_replies

static int
detail_question_replies_add

static int
drawer_layout

static int
favourite_list

static int
history_list

static int
item1

static int
later_list

static int
layout_bottom

static int
list_question_answer

static int
list_question_time

static int
list_question_title

static int
list_question_upvote

static int
list_question_upvote_caption

static int
loginText

static int
myquestion_list

static int
navigation_drawer

static int
question_ImageButton

static int
question_ImageView

static int
question_ImageViewFinal

static int
question_list

static int
question_upvote_caption

static int
questionBodyText

static int
questionTitleText

static int
replyBodyText

static int
setUsernameButton

static int
sort

static int
submitAnswerButton

static int
submitQuestionButton

static int
submitReplyButton

static int
swipe_container

static int
upvote_answer_button

static int
upvote_question_button

static int
view_question_detail

Constructor Summary

Constructors

Constructor and Description

id()

Method Summary

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

action_settings

public static final int action_settings

See Also:

Constant Field Values

add_answer_button

public static final int add_answer_button

See Also:

Constant Field Values

answerBodyText

public static final int answerBodyText

See Also:

Constant Field Values

answer_upvote_caption

public static final int answer_upvote_caption

See Also:

Constant Field Values

cancelAnswerButton

public static final int cancelAnswerButton

See Also:

Constant Field Values

cancelQuestionButton

public static final int cancelQuestionButton

See Also:

Constant Field Values

cancelReplyButton

public static final int cancelReplyButton

See Also:

Constant Field Values

container

public static final int container

See Also:

Constant Field Values

detail_answer_header

public static final int detail_answer_header

See Also:

Constant Field Values

detail_answer_replies

public static final int detail_answer_replies

See Also:

Constant Field Values

detail_answer_replies_add

public static final int detail_answer_replies_add

See Also:

Constant Field Values

detail_question_body

public static final int detail_question_body

See Also:

Constant Field Values

detail_question_header

public static final int detail_question_header

See Also:

Constant Field Values

detail_question_replies

public static final int detail_question_replies

See Also:

Constant Field Values

detail_question_replies_add

public static final int detail_question_replies_add

See Also:

Constant Field Values

drawer_layout

public static final int drawer_layout

See Also:

Constant Field Values

favourite_list

public static final int favourite_list

See Also:

Constant Field Values

history_list

public static final int history_list

See Also:

Constant Field Values

item1

public static final int item1

See Also:

Constant Field Values

later_list

public static final int later_list

See Also:

Constant Field Values

layout_bottom

public static final int layout_bottom

See Also:

Constant Field Values

list_question_answer

public static final int list_question_answer

See Also:

Constant Field Values

list_question_time

public static final int list_question_time

See Also:

Constant Field Values

list_question_title

public static final int list_question_title

See Also:

Constant Field Values

list_question_upvote

public static final int list_question_upvote

See Also:

Constant Field Values

list_question_upvote_caption

public static final int list_question_upvote_caption

See Also:

Constant Field Values

loginText

public static final int loginText

See Also:

Constant Field Values

myquestion_list

public static final int myquestion_list

See Also:

Constant Field Values

navigation_drawer

public static final int navigation_drawer

See Also:

Constant Field Values

questionBodyText

public static final int questionBodyText

See Also:

Constant Field Values

questionTitleText

public static final int questionTitleText

See Also:

Constant Field Values

question_ImageButton

public static final int question_ImageButton

See Also:

Constant Field Values

question_ImageView

public static final int question_ImageView

See Also:

Constant Field Values

question_ImageViewFinal

public static final int question_ImageViewFinal

See Also:

Constant Field Values

question_list

public static final int question_list

See Also:

Constant Field Values

question_upvote_caption

public static final int question_upvote_caption

See Also:

Constant Field Values

replyBodyText

public static final int replyBodyText

See Also:

Constant Field Values

setUsernameButton

public static final int setUsernameButton

See Also:

Constant Field Values

sort

public static final int sort

See Also:

Constant Field Values

submitAnswerButton

public static final int submitAnswerButton

See Also:

Constant Field Values

submitQuestionButton

public static final int submitQuestionButton

See Also:

Constant Field Values

submitReplyButton

public static final int submitReplyButton

See Also:

Constant Field Values

swipe_container

public static final int swipe_container

See Also:

Constant Field Values

upvote_answer_button

public static final int upvote_answer_button

See Also:

Constant Field Values

upvote_question_button

public static final int upvote_question_button

See Also:

Constant Field Values

view_question_detail

public static final int view_question_detail

See Also:

Constant Field Values

Constructor Detail

id

public id()

Skip navigation links

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

Prev Class

Next Class

Frames

No Frames

All Classes

Summary:

Nested |

Field |

Constr |

Method

Detail:

Field |

Constr |

Method


text:
import { Component, OnInit } from '@angular/core';
import { Location } from '@angular/common';
import { ROUTER_DIRECTIVES } from '@angular/router';

import { SidebarComponent } from './sidebar';
import { FormManager } from './shared';

@Component({
  moduleId: module.id,
  selector: 'app-angular2-multi-component-form-builder',
  templateUrl: 'angular2-multi-component-form-builder.component.html',
  styleUrls: ['angular2-multi-component-form-builder.component.css'],
  directives: [ROUTER_DIRECTIVES, SidebarComponent],
  providers: [FormManager]
})
export class Angular2MultiComponentFormBuilderComponent implements OnInit {

  title = 'Angular2 Multi Component Dynamic Form Builder Demo!';

  constructor(public location:Location) {}

  ngOnInit() {}

  getLinkStyle(path) {
  	return this.location.path().indexOf(path) > -1;
  }

}


text:
<?php

namespace dosamigos\leaflet\plugins\makimarker;

use yii\web\AssetBundle;

/**
 * MakiMarkerAsset
 *
 * @author Antonio Ramirez <amigo.cobos@gmail.com>
 * @link http://www.ramirezcobos.com/
 * @link http://www.2amigos.us/
 * @package dosamigos\leaflet\plugins\markercluster
 */
class MakiMarkerAsset extends AssetBundle
{

    public $sourcePath = '@vendor/2amigos/yii2-leaflet-makimarker-plugin/src/assets';

    public $js = ['js/Leaflet.MakiMarkers.js'];

    public $depends = [
        'dosamigos\leaflet\LeafLetAsset',
    ];
}


text:
using System.Text;

namespace T4TS
{
    public class EnumOutputAppender : OutputAppender<TypeScriptEnum>
    {
        public EnumOutputAppender(StringBuilder output, int baseIndentation, Settings settings)
            : base(output, baseIndentation, settings)
        {
        }

        public override void AppendOutput(TypeScriptEnum tsEnum)
        {
            BeginInterface(tsEnum);

            AppendMembers(tsEnum);

            EndInterface();
        }

        public void AppendOutputSubEnum(TypeScriptEnum tsEnum, TypeScriptInterface owner)
        {
            BeginInterface(tsEnum, owner);

            AppendMembers(tsEnum, owner);

            EndInterface(owner);
        }

        private void AppendMembers(TypeScriptEnum tsEnum, TypeScriptInterface owner = null)
        {
            int identation = 4;
            while (owner != null)
            {
                identation += 4;
                owner = owner.Owner;
            }
            var appender = new EnumMemberOutputAppender(Output, BaseIndentation + identation, Settings);
            foreach (TypeScriptEnumMember member in tsEnum.Members)
                appender.AppendOutput(member);
        }

        private void BeginInterface(TypeScriptEnum tsEnum, TypeScriptInterface owner = null)
        {
            AppendIndentedLine("/** Generated from " + tsEnum.FullName + " **/");
            if (owner == null)
            {
                AppendIndented("const enum " + tsEnum.Name);
            }
            else
            {
                string module = owner.Name;
                string enumName = tsEnum.Name;
                string[] arr = tsEnum.Name.Split('.');
                if (arr.Length > 1)
                {
                    module = arr[0];
                    enumName = arr[1];
                }
                AppendIndentedLine("export module " + module + " {");
                AppendIndendation();
                AppendIndented("const enum " + enumName);
            }
            Output.AppendLine(" {");
        }

        private void EndInterface(TypeScriptInterface owner = null)
        {
            while (owner != null)
            {
                AppendIndendation();
                AppendIndentedLine("}");
                owner = owner.Owner;
            }
            AppendIndentedLine("}");
        }
    }
}


text:
name: 📖 Documentation Issue
about: To report typo or obsolete section in the documentation

---


text:
interface IReadCommonBusiness<T> {
    retrieve: (callback: (error: any, result: T) => void) => void;
    findById: (id: string, callback: (error: any, result: T) => void) => void;

}

export = IReadCommonBusiness;


text:
.include <bsd.own.mk>

PROG=	phantasia
SRCS=	fight.c gamesupport.c interplayer.c io.c main.c misc.c phantglobs.c

DPADD=	${LIBM} ${LIBCURSES} ${LIBTERMINFO}
LDADD=	-lm -lcurses -lterminfo
HIDEGAME=hidegame
SETGIDGAME=yes
USETBL=
MAN=	phantasia.6

FILESDIR=/var/games/phantasia
FILESOWN=games
FILESGRP=games
FILESMODE=0660
ALLFILES=gold lastdead mess monsters void motd characs scoreboard
FILES=gold lastdead mess monsters void motd
# don't overwrite existing characters or scorefile
.for file in characs scoreboard
.if !exists(${DESTDIR}${FILESDIR}/${file})
FILES+=${file}
.endif
.endfor

CLEANFILES+=map mkdata setup.lo host_phantglobs.lo ${ALLFILES} files.stamp

realall: ${FILES}

${FILES}: files.stamp
files.stamp: mkdata monsters.asc
	${_MKMSG_CREATE} ${FILES}
	rm -f ${.TARGET}
	./mkdata -m ${.CURDIR}/monsters.asc
	touch ${.TARGET}

mkdata: host_phantglobs.lo setup.lo ${LIBM}
	${_MKTARGET_LINK}
	${HOST_LINK.c} -o ${.TARGET} ${.ALLSRC:M*.lo} -lm

BUILDSYMLINKS+=	phantglobs.c host_phantglobs.c
HOST_CPPFLAGS+=	-I${.CURDIR}

# Make Phantasia map.  Change the map commands reflect your installation.
# PLOTDEVICE is used for plotting the map.  Change as appropriate.

map: map.c
	${CC} -O ${.CURDIR}/map.c -lplot -o ${.TARGET}
	./map | plot > /dev/tty

.include <bsd.prog.mk>

.if defined(HAVE_GCC) && ${MACHINE_ARCH} == "vax"
COPTS.misc.c+=	-O0
.endif


text:
require "rails_helper"

RSpec.describe User, type: :model do
  context "validations" do
    it { is_expected.to validate_confirmation_of(:password) }
  end
end


text:
namespace Kangarooper.Text
{
    using System.Collections.Generic;
    using System.Linq;

    public static partial class CharExtensions
    {
        /// <summary>
        /// Creates and returns a new string containing all of the characters in the provided enumeration.
        /// </summary>
        public static string ToNewString(this IEnumerable<char> chars) => new string(chars.ToArray());
    }
}


text:
package com.intellij.openapi.fileEditor.impl.http;

import com.intellij.icons.AllIcons;
import com.intellij.openapi.actionSystem.ActionManager;
import com.intellij.openapi.actionSystem.ActionPlaces;
import com.intellij.openapi.actionSystem.ActionToolbar;
import com.intellij.openapi.actionSystem.DefaultActionGroup;
import com.intellij.openapi.application.ApplicationManager;
import consulo.awt.TargetAWT;
import consulo.logging.Logger;
import com.intellij.openapi.fileEditor.TextEditor;
import com.intellij.openapi.options.ShowSettingsUtil;
import com.intellij.openapi.project.Project;
import consulo.disposer.Disposer;
import com.intellij.openapi.vfs.VirtualFile;
import com.intellij.openapi.vfs.impl.http.FileDownloadingListener;
import com.intellij.openapi.vfs.impl.http.HttpVirtualFile;
import com.intellij.openapi.vfs.impl.http.RemoteFileInfo;
import com.intellij.openapi.vfs.impl.http.RemoteFileState;
import com.intellij.util.EventDispatcher;
import com.intellij.util.net.HttpProxyConfigurable;
import com.intellij.util.ui.UIUtil;
import com.intellij.util.ui.update.MergingUpdateQueue;
import com.intellij.util.ui.update.Update;
import consulo.fileEditor.impl.text.TextEditorProvider;
import kava.beans.PropertyChangeEvent;
import kava.beans.PropertyChangeListener;
import org.jetbrains.annotations.NonNls;

import javax.annotation.Nonnull;
import javax.annotation.Nullable;
import javax.swing.*;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;

/**
 * @author nik
 */
public class RemoteFilePanel implements PropertyChangeListener {
  private static final Logger LOG = Logger.getInstance(RemoteFilePanel.class);
  @NonNls private static final String ERROR_CARD = "error";
  @NonNls private static final String DOWNLOADING_CARD = "downloading";
  @NonNls private static final String EDITOR_CARD = "editor";
  private JPanel myMainPanel;
  private JLabel myProgressLabel;
  private JProgressBar myProgressBar;
  private JButton myCancelButton;
  private JPanel myContentPanel;
  private JLabel myErrorLabel;
  private JButton myTryAgainButton;
  private JButton myChangeProxySettingsButton;
  private JPanel myEditorPanel;
  private JTextField myUrlTextField;
  private JPanel myToolbarPanel;
  private final Project myProject;
  private final HttpVirtualFile myVirtualFile;
  private final MergingUpdateQueue myProgressUpdatesQueue;
  private final MyDownloadingListener myDownloadingListener;
  private final EventDispatcher<PropertyChangeListener> myDispatcher = EventDispatcher.create(PropertyChangeListener.class);
  private @Nullable
  TextEditor myFileEditor;

  public RemoteFilePanel(final Project project, final HttpVirtualFile virtualFile) {
    myProject = project;
    myVirtualFile = virtualFile;
    myErrorLabel.setIcon(TargetAWT.to(AllIcons.RunConfigurations.ConfigurationWarning));
    myUrlTextField.setText(virtualFile.getUrl());
    myProgressUpdatesQueue = new MergingUpdateQueue("downloading progress updates", 300, false, myMainPanel);
    initToolbar(project);

    final RemoteFileInfo remoteFileInfo = virtualFile.getFileInfo();
    myDownloadingListener = new MyDownloadingListener();
    remoteFileInfo.addDownloadingListener(myDownloadingListener);
    myCancelButton.addActionListener(new ActionListener() {
      public void actionPerformed(final ActionEvent e) {
        remoteFileInfo.cancelDownloading();
      }
    });

    myTryAgainButton.addActionListener(new ActionListener() {
      public void actionPerformed(final ActionEvent e) {
        showCard(DOWNLOADING_CARD);
        remoteFileInfo.restartDownloading();
      }
    });
    myChangeProxySettingsButton.addActionListener(new ActionListener() {
      public void actionPerformed(final ActionEvent e) {
        ShowSettingsUtil.getInstance().editConfigurable(myMainPanel, new HttpProxyConfigurable());
      }
    });
    showCard(DOWNLOADING_CARD);
    remoteFileInfo.startDownloading();
    if (remoteFileInfo.getState() == RemoteFileState.DOWNLOADED) {
      switchEditor();
    }
    else {
      String errorMessage = remoteFileInfo.getErrorMessage();
      if (errorMessage != null) {
        myDownloadingListener.errorOccurred(errorMessage);
      }
    }
  }

  private void initToolbar(Project project) {
    DefaultActionGroup group = new DefaultActionGroup();
    group.add(new RefreshRemoteFileAction(myVirtualFile));
    for (RemoteFileEditorActionProvider actionProvider : RemoteFileEditorActionProvider.EP_NAME.getExtensions()) {
      group.addAll(actionProvider.createToolbarActions(project, myVirtualFile));
    }
    final ActionToolbar actionToolbar = ActionManager.getInstance().createActionToolbar(ActionPlaces.UNKNOWN, group, true);
    myToolbarPanel.add(actionToolbar.getComponent(), BorderLayout.CENTER);
  }

  private void showCard(final String name) {
    ((CardLayout)myContentPanel.getLayout()).show(myContentPanel, name);
  }

  private void switchEditor() {
    LOG.debug("Switching editor...");
    ApplicationManager.getApplication().invokeLater(new Runnable() {
      public void run() {
        final TextEditor textEditor = (TextEditor)TextEditorProvider.getInstance().createEditor(myProject, myVirtualFile);
        textEditor.addPropertyChangeListener(RemoteFilePanel.this);
        myEditorPanel.removeAll();
        myEditorPanel.add(textEditor.getComponent(), BorderLayout.CENTER);
        myFileEditor = textEditor;
        showCard(EDITOR_CARD);
        LOG.debug("Editor for downloaded file opened.");
      }
    });
  }

  @Nullable
  public TextEditor getFileEditor() {
    return myFileEditor;
  }

  public JPanel getMainPanel() {
    return myMainPanel;
  }

  public void selectNotify() {
    UIUtil.invokeLaterIfNeeded(new Runnable() {
      public void run() {
        myProgressUpdatesQueue.showNotify();
        if (myFileEditor != null) {
          myFileEditor.selectNotify();
        }
      }
    });
  }

  public void deselectNotify() {
    UIUtil.invokeLaterIfNeeded(new Runnable() {
      public void run() {
        myProgressUpdatesQueue.hideNotify();
        if (myFileEditor != null) {
          myFileEditor.deselectNotify();
        }
      }
    });
  }

  public void dispose() {
    myVirtualFile.getFileInfo().removeDownloadingListener(myDownloadingListener);
    myProgressUpdatesQueue.dispose();
    if (myFileEditor != null) {
      Disposer.dispose(myFileEditor);
    }
  }

  public void addPropertyChangeListener(PropertyChangeListener listener) {
    myDispatcher.addListener(listener);
  }

  public void removePropertyChangeListener(PropertyChangeListener listener) {
    myDispatcher.removeListener(listener);
  }

  public void propertyChange(PropertyChangeEvent evt) {
    myDispatcher.getMulticaster().propertyChange(evt);
  }

  private class MyDownloadingListener implements FileDownloadingListener {
    public void fileDownloaded(final VirtualFile localFile) {
      switchEditor();
    }

    public void downloadingCancelled() {
      ApplicationManager.getApplication().invokeLater(new Runnable() {
        public void run() {
          if (myFileEditor != null) {
            showCard(EDITOR_CARD);
          }
          else {
            myErrorLabel.setText("Downloading cancelled");
            showCard(ERROR_CARD);
          }
        }
      });
    }

    public void downloadingStarted() {
      ApplicationManager.getApplication().invokeLater(new Runnable() {
        public void run() {
          showCard(DOWNLOADING_CARD);
        }
      });
    }

    public void errorOccurred(@Nonnull final String errorMessage) {
      ApplicationManager.getApplication().invokeLater(new Runnable() {
        public void run() {
          myErrorLabel.setText(errorMessage);
          showCard(ERROR_CARD);
        }
      });
    }

    public void progressMessageChanged(final boolean indeterminate, @Nonnull final String message) {
      myProgressUpdatesQueue.queue(new Update("progress text") {
        public void run() {
          myProgressLabel.setText(message);
        }
      });
    }

    public void progressFractionChanged(final double fraction) {
      myProgressUpdatesQueue.queue(new Update("fraction") {
        public void run() {
          myProgressBar.setValue((int)Math.round(100*fraction));
        }
      });
    }
  }
}


text:
import {Component, Input, OnInit} from '@angular/core';

@Component({
  selector: 'app-spacer',
  templateUrl: './spacer.component.html',
  styleUrls: ['./spacer.component.scss']
})
export class SpacerComponent implements OnInit {
  @Input() height: string | number;

  constructor() {}

  ngOnInit() {}

  get getHeight(): string {
    return this.height ? this.height + 'px' : '10px';
  }
}


text:
package caslock

import (
	"errors"
	"fmt"
	"log"
	"time"

	"github.com/gocql/gocql"
)

var (
	// LockColumn is the name of the column used to control row locks. It
	// must added to the desired column family before using caslock.
	LockColumn = "[lock]"

	// RetryTime is the time beteween retries when a row has been locked by
	// another process.
	RetryTime = 500 * time.Millisecond

	// Log is the logger used to register warnings and info messages. If it is nil,
	// no messages will be logged.
	Log *log.Logger
)

// Lock represents a cassandra's row lock.
type Lock struct {
	lockID   gocql.UUID
	keyspace string
	table    string
	rowKeys  []interface{}
	ttl      time.Duration
	timeout  time.Duration
	session  *gocql.Session
}

var errTimeout = errors.New("cannot satisfy timeout value")

// Acquire locks the rows in rowKeys on the table keyspace.table. The parameter
// timeout defines the minimum time that the rows will locked before being
// automatically released.
func Acquire(session *gocql.Session, keyspace, table string, timeout time.Duration, rowKeys ...interface{}) (*Lock, error) {
	l := &Lock{
		lockID:   gocql.TimeUUID(),
		keyspace: keyspace,
		table:    table,
		rowKeys:  rowKeys,
		ttl:      timeout * 2,
		timeout:  timeout,
		session:  session,
	}

loop:
	for {
		switch err := l.acquireLoop(); err {
		case nil:
			break loop
		case errTimeout:
			continue loop
		default:
			return nil, err
		}
	}
	return l, nil
}

func (l *Lock) acquireLoop() error {
	var maxTime time.Time
	for i, k := range l.rowKeys {
		for {
			if i == 0 {
				maxTime = time.Now().Add(l.ttl)
			} else if maxTime.Sub(time.Now()) < l.timeout {
				logf("cannot satisfy timeout, restarting acquire")
				l.Release()
				return errTimeout
			}

			applied, err := l.lockRow(k)
			if err != nil {
				l.Release()
				return err
			}
			if applied {
				break
			}

			// check if the rows really exist before retrying
			if err := l.checkRows(); err != nil {
				l.Release()
				return err
			}

			time.Sleep(RetryTime)
		}
	}
	return nil
}

func (l *Lock) lockRow(row interface{}) (applied bool, err error) {
	var prevLockID gocql.UUID
	q := fmt.Sprintf("UPDATE %q.%q USING TTL ? SET %q = ?"+
		" WHERE id = ? IF %q = null",
		l.keyspace, l.table, LockColumn, LockColumn)
	applied, err = l.session.Query(q, int(l.ttl.Seconds()),
		l.lockID, row).ScanCAS(&prevLockID)
	if !applied {
		logf("cannot lock row: lock key=%v lockID=%v prevLockID=%v\n",
			row, l.lockID, prevLockID)
	}
	return
}

func (l *Lock) checkRows() error {
	var countRows int
	q := fmt.Sprintf("SELECT COUNT(*) FROM %q.%q WHERE id in ?",
		l.keyspace, l.table)
	if err := l.session.Query(q, l.rowKeys).Scan(&countRows); err != nil {
		return err
	}
	if countRows != len(l.rowKeys) {
		return errors.New("key not found")
	}
	return nil
}

// Release releases the lock.
func (l *Lock) Release() error {
	for _, k := range l.rowKeys {
		q := fmt.Sprintf("UPDATE %q.%q SET %q = null WHERE id = ? IF %q = ?",
			l.keyspace, l.table, LockColumn, LockColumn)
		if _, err := l.session.Query(q, k, l.lockID).ScanCAS(); err != nil {
			return err
		}
	}
	return nil
}

func logf(format string, args ...interface{}) {
	if Log == nil {
		return
	}
	Log.Printf(format, args...)
}


text:
FROM appcelerator/gotools:1.15.0

RUN rm -rf /etc/apk/repositories
RUN echo "http://dl-cdn.alpinelinux.org/alpine/edge/main" >> /etc/apk/repositories
RUN echo "http://dl-cdn.alpinelinux.org/alpine/edge/community" >> /etc/apk/repositories
RUN echo "http://dl-cdn.alpinelinux.org/alpine/edge/testing" >> /etc/apk/repositories
RUN apk update
RUN apk add gosu docker make nodejs jq

## swagger-combine for API documentation
RUN npm install --save swagger-combine

## originally: -rwxr-xr-x 1 root root 1687016 Jan 24  2017 /usr/sbin/gosu
## adding the sticky bit to allow users to execute command as root
RUN adduser -D -g "" -s /bin/sh sudoer
RUN chgrp sudoer /usr/bin/gosu && chmod +s /usr/bin/gosu

# pass commands through docker-entrypoint first for special handling
# it's fine to override entrypoint if not running a docker command
COPY docker-entrypoint.sh /usr/local/bin/
ENTRYPOINT ["docker-entrypoint.sh"]
CMD ["sh"]


text:
package com.mongodb.migratecluster.commandline;

import com.mongodb.migratecluster.utils.StringUtils;
import org.apache.commons.cli.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * File: InputArgsParser
 * Author: shyam.arjarapu
 * Date: 4/13/17 11:47 PM
 * Description:
 */
public class InputArgsParser {
    final static Logger logger = LoggerFactory.getLogger(InputArgsParser.class);

    Options options;
    Boolean areOptionsSet = false;

    public InputArgsParser() {
        options = new Options();
    }

    public void loadSupportedOptions() {
        if (!areOptionsSet) {

            options.addOption("h", "help", false, "print this message");
            options.addOption("c", "config", true,"configuration file for migration");
            options.addOption("s", "source", true,"source cluster connection string");
            options.addOption("t", "target", true,"target cluster connection string");
            options.addOption("o", "oplog", false,"oplogStore connection string. only required if oplog headroom is small");
            options.addOption("d", "drop", false,"drop target collections before copying");

            areOptionsSet = true;
        }
    }

    public CommandLine parse(String[] args) throws ParseException {
        CommandLineParser parser = new DefaultParser();
        CommandLine cmd = null;
        cmd = parser.parse(options, args);
        return cmd;
    }

    public void printHelp() {
        HelpFormatter formatter = new HelpFormatter();
        formatter.printHelp("migratecluster", options, true);
    }

    public ApplicationOptions getApplicationOptions(String[] args) {
        this.loadSupportedOptions();
        ApplicationOptions appOptions = new ApplicationOptions();
        CommandLine cmd = null;

        // if requested for help or has exceptions while parsing, show help.
        try {
            cmd = this.parse(args);
        } catch (ParseException e) {
            appOptions.setShowHelp(true);
            return appOptions;

        }
        if (cmd.hasOption("h")) {
            appOptions.setShowHelp(true);
            return appOptions;
        }

        // set parsed input values to corresponding properties
        if (cmd.hasOption("c")) {
            appOptions.setConfigFilePath(StringUtils.valueOrDefault(cmd.getOptionValue("c")));
        }
        if (cmd.hasOption("s")) {
            appOptions.setSourceCluster(StringUtils.valueOrDefault(cmd.getOptionValue("s")));
        }
        if (cmd.hasOption("t")) {
            appOptions.setTargetCluster(StringUtils.valueOrDefault(cmd.getOptionValue("t")));
        }
        if (cmd.hasOption("o")) {
            appOptions.setOplogStore(StringUtils.valueOrDefault(cmd.getOptionValue("o")));
        }
        if (cmd.hasOption("d")) {
            appOptions.setDropTarget(true);
        }
        return appOptions;
    }
}


text:
using System.Collections;
using System.Collections.Generic;
using UnityEngine;

namespace Nanosoft
{

/**
 * Точка входа в сцену для TabletController
 */
public class TabletEntry: MonoBehaviour
{

	/**
	 * Префаб с контроллером который надо инстанцировать
	 */
	public GameObject prefab;

	/**
	 * Пустышка которую чье отображение надо отключить
	 */
	public GameObject dummy;

	public string backgroundMusic;

	void Awake()
	{
		if ( TabletController.instance == null )
		{
			Time.timeScale = 0f;
			var t = gameObject.transform;
			var obj = Instantiate(prefab, t.position, t.rotation);
			obj.name = prefab.name;
		}

		if ( dummy != null )
		{
			dummy.SetActive(false);
		}
	}

} // class TabletEntry

} // namespace Nanosoft


text:
Atari games [wiki](https://en.wikipedia.org/wiki/List_of_Atari_2600_games)

## Create
* Python name: ```atari```
* C++ constructor name: ```ArcadeGame```
* Name for the unified C++ simulator interface: ```atari```

## Flags
|**Name**|**Description**|
|:-------|:---------------|
|```pause_screen```|Pause the screen when show_screen() is called, until any key is pressed. (Default: false)|
|```ale_rom```|The Atari ROM file. You need to download the ROMs (.bin files) yourself. For exampe, from [here](https://github.com/npow/atari/tree/master/roms). (Default: "")|
|```context```|How many consecutive frames are used to represent the current sensor input. (Default: 1)|


text:
import os
import subprocess

from tests.util import Failure, Success, project_path

def run():
    CONF_DIR = os.path.join(project_path(),
                            'buildbot', 'master', 'files', 'config')
    # Have to specify master.cfg separately because it is not a .py file
    command = ['flake8', CONF_DIR, os.path.join(CONF_DIR, 'master.cfg')]
    ret = subprocess.run(command,
                         stdout=subprocess.PIPE,
                         stderr=subprocess.PIPE,
                         universal_newlines=True)

    if ret.returncode == 0:
        return Success("Buildbot master config passed linting")
    else:
        return Failure("Buildbot master config lint check failed:", ret.stdout)


text:
<?php

namespace App\Http\Controllers\barang;

use App\Http\Requests;
use App\Http\Controllers\Controller;

use App\barang;
use Illuminate\Http\Request;
use Carbon\Carbon;
use Session;
use DB;

class barangController extends Controller
{

    /**
     * Display a listing of the resource.
     *
     * @return Response
     */
    public function index()
    {
        $barang = barang::paginate(15);

        return view('barang.index', compact('barang'));
    }

    /**
     * Show the form for creating a new resource.
     *
     * @return Response
     */
    public function create()
    {
        $kategori = DB::table('kategori')->lists('kategori', 'kategori_id');
        $jenis = DB::table('jenis')->lists('nama_jenis', 'jenis_id');
        $satuan = DB::table('satuan')->lists('nama_sat', 'satuan_id');
        $merk = DB::table('merk')->lists('namamerk', 'merk_id');
        return view('barang.create')->with('kategori', $kategori)
                                    ->with('jenis', $jenis)
                                    ->with('satuan', $satuan)
                                    ->with('merk', $merk);
    }

    /**
     * Store a newly created resource in storage.
     *
     * @return Response
     */
    public function store(Request $request)
    {
        $this->validate($request, ['kategori_id' => 'required', 'jenis_id' => 'required', 'merk_id' => 'required', 'satuan_id' => 'required', 'nama' => 'required', 'stok' => 'required', 'konversi' => 'required', ]);

        barang::create($request->all());

        Session::flash('flash_message', 'barang Telah Ditambahkan!');

        return redirect('barang');
    }

    /**
     * Display the specified resource.
     *
     * @param  int  $barang_id
     *
     * @return Response
     */
    public function show($barang_id)
    {
        $barang = barang::findOrFail($barang_id);
        $kategori = DB::table('kategori')->lists('kategori', 'kategori_id');
        $jenis = DB::table('jenis')->lists('nama_jenis', 'jenis_id');
        $satuan = DB::table('satuan')->lists('nama_sat', 'satuan_id');
        $merk = DB::table('merk')->lists('namamerk', 'merk_id');
        return view('barang.show', compact('barang'))
                                    ->with('kategori', $kategori)
                                    ->with('jenis', $jenis)
                                    ->with('satuan', $satuan)
                                    ->with('merk', $merk);
    }

    /**
     * Show the form for editing the specified resource.
     *
     * @param  int  $barang_id
     *
     * @return Response
     */
    public function edit($barang_id)
    {
        $barang = barang::findOrFail($barang_id);

        return view('barang.edit', compact('barang'));
    }

    /**
     * Update the specified resource in storage.
     *
     * @param  int  $barang_id
     *
     * @return Response
     */
    public function update($barang_id, Request $request)
    {
        $this->validate($request, ['kategori_id' => 'required', 'jenis_id' => 'required', 'merk_id' => 'required', 'satuan_id' => 'required', 'nama' => 'required', 'stok' => 'required', 'konversi' => 'required', ]);

        $barang = barang::findOrFail($barang_id);
        $barang->update($request->all());

        Session::flash('flash_message', 'barang Telah Diupdate!');

        return redirect('barang');
    }

    /**
     * Remove the specified resource from storage.
     *
     * @param  int  $barang_id
     *
     * @return Response
     */
    public function destroy($barang_id)
    {
        barang::destroy($barang_id);

        Session::flash('flash_message', 'barang Telah Dihapus!');

        return redirect('barang');
    }

}


text:
namespace MassTransit.RabbitMqTransport.Configuration
{
    using MassTransit.Configuration;
    using Topology;
    using Transport;

    public interface IRabbitMqReceiveEndpointConfiguration :
        IReceiveEndpointConfiguration,
        IRabbitMqEndpointConfiguration
    {
        IRabbitMqReceiveEndpointConfigurator Configurator { get; }

        IRabbitMqBusConfiguration BusConfiguration { get; }

        IRabbitMqHostControl Host { get; }

        bool BindMessageExchanges { get; set; }

        ReceiveSettings Settings { get; }
    }
}