// Path: src/test/java/com/lmax/disruptor/support/TestEvent.java
// public final class TestEvent
// {
//     @Override
//     public String toString()
//     {
//         return "Test Event";
//     }
// 
//     public final static EventFactory<TestEvent> EVENT_FACTORY = new EventFactory<TestEvent>()
//     {
//         public TestEvent newInstance()
//         {
//             return new TestEvent();
//         }
//     };
// }


import static org.hamcrest.CoreMatchers.equalTo;
import static org.junit.Assert.*;
import com.lmax.disruptor.*;
import com.lmax.disruptor.support.TestEvent;
import com.lmax.disruptor.dsl.stubs.*;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.util.ArrayList;
import java.util.Collection;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.Executor;
import java.util.concurrent.atomic.AtomicReference;
import static java.lang.Thread.yield;
import static java.util.concurrent.TimeUnit.*;
/*
 * Copyright 2011 LMAX Ltd.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.lmax.disruptor.dsl;




@SuppressWarnings(value = {"ThrowableResultOfMethodCallIgnored", "unchecked"})
public class DisruptorTest
{
    private static final int TIMEOUT_IN_SECONDS = 2;
// Path: src/test/java/com/lmax/disruptor/support/TestEvent.java
// public final class TestEvent
// {
//     @Override
//     public String toString()
//     {
//         return "Test Event";
//     }
// 
//     public final static EventFactory<TestEvent> EVENT_FACTORY = new EventFactory<TestEvent>()
//     {
//         public TestEvent newInstance()
//         {
//             return new TestEvent();
//         }
//     };
// }


// Path: src/test/java/com/lmax/disruptor/dsl/DisruptorTest.java
import static org.hamcrest.CoreMatchers.equalTo;
import static org.junit.Assert.*;
import com.lmax.disruptor.*;
import com.lmax.disruptor.support.TestEvent;
import com.lmax.disruptor.dsl.stubs.*;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.util.ArrayList;
import java.util.Collection;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.Executor;
import java.util.concurrent.atomic.AtomicReference;
import static java.lang.Thread.yield;
import static java.util.concurrent.TimeUnit.*;

/*
 * Copyright 2011 LMAX Ltd.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.lmax.disruptor.dsl;




@SuppressWarnings(value = {"ThrowableResultOfMethodCallIgnored", "unchecked"})
public class DisruptorTest
{
    private static final int TIMEOUT_IN_SECONDS = 2;
    private Disruptor<TestEvent> disruptor;