import com.thalmic.myo.Hub; //导入依赖的package包/类
public void onDemoPressed(View v)
{
    final Hub hub = Hub.getInstance();
    Thread t1 = new Thread(new Runnable() {
        public void run() {
            if(hub.getConnectedDevices().isEmpty())
            {
                Log.e("Logue_SSJ", "device not found");
            }
            else
            {
                com.thalmic.myo.Myo myo = hub.getConnectedDevices().get(0);
                startVibrate(myo, hub);
            }
        }
    });
    t1.start();
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
@Override
public boolean connect() throws Exception {
    Log.d("", "preConnect");
    super.connect();
    // First, we initialize the Hub singleton with an application identifier.
    Hub hub = Hub.getInstance();
    if (!hub.init(mContext, mContext.getPackageName())) {
        // We can't do anything with the Myo device if the Hub can't be initialized, so exit.
        //Toast.makeText(this, "Couldn't initialize Hub", Toast.LENGTH_SHORT).show();
        //finish();
        return false;
    }
    // Next, register for DeviceListener callbacks.
    hub.addListener(mListener);
    hub.attachToAdjacentMyo();

    sendConnected();

    return true;
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
public void connect() {

		hub = new Hub("com.example.hello-myo");

		System.out.println("Attempting to find a Myo...");
		log.info("Attempting to find a Myo");
		myo = hub.waitForMyo(10000);

		if (myo == null) {
			// throw new RuntimeException("Unable to find a Myo!");
			log.info("Unable to find a Myo");
		}

		System.out.println("Connected to a Myo armband!");
		log.info("Connected to a Myo armband");
		hub.addListener(this);
		
		if (hubThread == null){
			hubThread = new HubThread(this);
			hubThread.start();
		}

	}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
public static void main(String[] args) {
	try {
		Hub hub = new Hub("com.example.emg-data-sample");

		System.out.println("Attempting to find a Myo...");
		Myo myo = hub.waitForMyo(10000);

		if (myo == null) {
			throw new RuntimeException("Unable to find a Myo!");
		}

		System.out.println("Connected to a Myo armband!");
		myo.setStreamEmg(StreamEmgType.STREAM_EMG_ENABLED);
		DeviceListener dataCollector = new EmgDataCollector();
		hub.addListener(dataCollector);

		while (true) {
			hub.run(1000 / 20);
			System.out.println(dataCollector);
		}
	} catch (Exception e) {
		System.err.println("Error: ");
		e.printStackTrace();
		System.exit(1);
	}
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
public static void main(String... args) {
	try {
		Hub hub = new Hub("com.example.multiple-myos");

		DeviceListener printer = new PrintMyoEvents();
		hub.addListener(printer);

		while (true) {
			hub.run(10);
		}
	} catch (Exception e) {
		System.err.println("Error: ");
		e.printStackTrace();
		System.exit(1);
	}
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
public static void main(String[] args) {
	try {
		Hub hub = new Hub("com.example.hello-myo");

		System.out.println("Attempting to find a Myo...");
		Myo myo = hub.waitForMyo(10000);

		if (myo == null) {
			throw new RuntimeException("Unable to find a Myo!");
		}

		System.out.println("Connected to a Myo armband!");
		DeviceListener dataCollector = new DataCollector();
		hub.addListener(dataCollector);

		while (true) {
			hub.run(1000 / 20);
			System.out.print(dataCollector);
		}
	} catch (Exception e) {
		System.err.println("Error: ");
		e.printStackTrace();
		System.exit(1);
	}
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
@Override
public void onCreate(Bundle savedInstanceState) {
  super.onCreate(savedInstanceState);
  mMapView = MapService.getMap(this);
  Log.d("ArcGIS", "Entering MapActivity");
  initGestureDetector(this);
  initSensors(this);
  getWindow().addFlags(WindowManager.LayoutParams.FLAG_KEEP_SCREEN_ON);
  setContentView(mMapView);
  Hub hub = Hub.getInstance();
  if (!hub.init(this, getPackageName())) {
    // We can't do anything with the Myo device if the Hub can't be initialized, so exit.
    Toast.makeText(this, "Couldn't initialize Hub", Toast.LENGTH_SHORT).show();
    finish();
    return;
  }
  mListener = new MyoMapListener(this, mMapView);
  hub.addListener(mListener);
  hub.setLockingPolicy(Hub.LockingPolicy.NONE);
  hub.attachToAdjacentMyo();
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
public void switchMyoListener() {
  Hub hub = Hub.getInstance();
  String message;
  if(mIsFeatureControl) {
    message = "Switching to map control";
    hub.removeListener(mFeatureControlListener);
    mMapControlListener.prepareSwitch();
    hub.addListener(mMapControlListener);
  } else {
    message = "Switching to feature control";
    hub.removeListener(mMapControlListener);
    mFeatureControlListener.prepareSwitch();
    hub.addListener(mFeatureControlListener);
  }
  mIsFeatureControl = !mIsFeatureControl;
  Toast.makeText(this, message, Toast.LENGTH_SHORT).show();
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
@Override
protected void onStop() {
  if(mGoogleApiClient != null && mGoogleApiClient.isConnected()) {
    Wearable.MessageApi.removeListener(mGoogleApiClient, mWearMessageListener);
    mGoogleApiClient.disconnect();
  }
  // We don't want any callbacks when the Activity is gone, so unregister the listener.
  Hub.getInstance().removeListener(mFeatureControlListener);
  Hub.getInstance().removeListener(mMapControlListener);

  if (isFinishing()) {
    // The Activity is finishing, so shutdown the Hub. This will disconnect from the Myo.
    Hub.getInstance().shutdown();
  }
  super.onStop();
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
private void myoInitialization() {
    // Hub initialization (manages Myo instances)
    mHub = Hub.getInstance();
    boolean status = mHub.init(this);

    // checks Hub initialization (fails if the system doesn't support Bluetooth Low Energy)
    if (!status) {
        Toast.makeText(this, "Bluetooth Low Energy not available. Aborting.", Toast.LENGTH_LONG).show();
    } else {
        // prevents statistics data to be sent
        mHub.setSendUsageData(false);
        mHub.addListener(new DeviceListener(this));
    }

    // pairing with the nearest device (unattended mode)
    mHub.attachToAdjacentMyo();
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
public Configuration(Hub hub, final MyoListener listener, EmgMode emg, boolean imu, boolean gestures)
{
    super(hub);
    _name = "Myo_Config";

    this.hub = hub;
    mListener = listener;

    this.emgMode = emg;
    this.imuMode = imu;
    this.gesturesMode = gestures;
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
@Override
public void disconnect() {
    super.disconnect();
    // We don't want any callbacks when the Activity is gone, so unregister the listener.
    Hub.getInstance().removeListener(mListener);
    // The Activity is finishing, so shutdown the Hub. This will disconnect from the Myo.
    Hub.getInstance().shutdown();

    sendDisconnected();
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
public static void main(String[] args) {
	LoggingFactory.getInstance().configure();
	LoggingFactory.getInstance().setLevel(Level.INFO);

	try {

		MyoThalmic myo = (MyoThalmic) Runtime.start("myo", "MyoThalmic");
		myo.test();

		Hub hub = new Hub("com.example.hello-myo");

		System.out.println("Attempting to find a Myo...");
		log.info("Attempting to find a Myo");

		Myo myodevice = hub.waitForMyo(10000);

		if (myodevice == null) {
			throw new RuntimeException("Unable to find a Myo!");
		}

		System.out.println("Connected to a Myo armband!");
		log.info("Connected to a Myo armband");
		DeviceListener dataCollector = new DataCollector();
		hub.addListener(dataCollector);

		while (true) {
			hub.run(1000 / 20);
			System.out.print(dataCollector);

			Runtime.start("gui", "GUIService");

		}
	} catch (Exception e) {
		Logging.logError(e);
	}
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
@Override
protected void onDestroy() {
	super.onDestroy();
	Hub.getInstance().removeListener(listener);
	if (isFinishing())
		Hub.getInstance().shutdown();
	
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
@Override
protected void onDestroy() {
  Log.d("ArcGIS", "Exiting MapActivity, removing view");
  mSensorManager.unregisterListener(this);
  ((ViewGroup)mMapView.getParent()).removeView(mMapView);
  Hub.getInstance().removeListener(mListener);
  if (isFinishing()) {
    // The Activity is finishing, so shutdown the Hub. This will disconnect from the Myo.
    Hub.getInstance().shutdown();
  }
  if(!mDying)
    MapService.returnToLiveCard();
  super.onDestroy();
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
@Override
protected void onCreate(Bundle savedInstanceState) {
  super.onCreate(savedInstanceState);
  // First, we initialize the Hub singleton
  final Hub hub = Hub.getInstance();
  if (!hub.init(this, getPackageName())) {
    // We can't do anything with the Myo device if the Hub can't be initialized, so exit.
    Toast.makeText(this, "Couldn't initialize Hub", Toast.LENGTH_SHORT).show();
    finish();
    return;
  }
  hub.setLockingPolicy(Hub.LockingPolicy.NONE);
  // Connects to a Myo that is physically touching the device
  hub.attachToAdjacentMyo();
  mMapView = new MapView(this, "http://csf.maps.arcgis.com/home/item.html?id=f065c8fa4e514749aeef57919b3d192e", null, null);
  mMapView.setOnStatusChangedListener(new OnStatusChangedListener() {
    @Override
    public void onStatusChanged(Object source, STATUS status) {
      if (source instanceof ArcGISFeatureLayer && status == STATUS.LAYER_LOADED) {
        mFeatureControlListener = new MyoFeatureControlListener(MainActivity.this, mMapView, (ArcGISFeatureLayer) source);
      }
    }
  });
  mMapControlListener = new MyoMapControlListener(this, mMapView);
  hub.addListener(mMapControlListener);
  setContentView(mMapView);
  mWearMessageListener = new WearMessageListener(mMapView);
  initGoogleApiClient();
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
private void startVibrate(Myo myo, Hub hub) {
    String _name = "test";
    Log.i(_name, "connected");
    try {
        Vibrate2Command vibrate2Command = new Vibrate2Command(hub);

        Log.i(_name, "vibrate 1...");
        myo.vibrate(Myo.VibrationType.MEDIUM);
        Thread.sleep(3000);

        Log.i(_name, "vibrate 2...");
        //check strength 50
        vibrate2Command.vibrate(myo, 1000, (byte) 50);
        Thread.sleep(3000);

        Log.i(_name, "vibrate 3 ...");
        //check strength 100
        vibrate2Command.vibrate(myo, 1000, (byte) 100);
        Thread.sleep(3000);

        Log.i(_name, "vibrate 4 ...");
        //check strength 100
        vibrate2Command.vibrate(myo, 1000, (byte) 150);
        Thread.sleep(3000);

        Log.i(_name, "vibrate 5...");
        //check strength 250
        vibrate2Command.vibrate(myo, 1000, (byte) 200);
        Thread.sleep(3000);

        Log.i(_name, "vibrate 6...");
        //check strength 250
        vibrate2Command.vibrate(myo, 1000, (byte) 250);
        Thread.sleep(3000);

        Log.i(_name, "vibrate pattern...");
        //check vibrate pattern
        vibrate2Command.vibrate(myo, new int[]{500, 500, 500, 500, 500, 500}, new byte[]{25, 50, 100, (byte) 150, (byte) 200, (byte) 250});
        Thread.sleep(3000);
    } catch (Exception e) {
        Log.e(_name, "exception in vibrate test", e);
    }
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
public void run()
{
	finished = false;

	// Check if hub can be initialized
	if (!hub.init(SSJApplication.getAppContext()))
	{
		errorMsg = "Could not initialize the Hub.";
		finished = true;
		return;
	}
	else
	{
		myoInitialized = true;
	}

	hub.setLockingPolicy(options.locking.get() ? Hub.LockingPolicy.STANDARD : Hub.LockingPolicy.NONE);

	// Disable usage data sending
	hub.setSendUsageData(false);

	// Add listener for callbacks
	hub.addListener(listener);

	// Connect to myo
	if (hub.getConnectedDevices().isEmpty())
	{
		// If there is a mac address connect to it, otherwise look for myo nearby
		if (options.macAddress.get() != null && !options.macAddress.get().isEmpty())
		{
			Log.i("Connecting to MAC: " + options.macAddress.get());
			hub.attachByMacAddress(options.macAddress.get());
		}
		else
		{
			//Log.i("Connecting to nearest myo");
			//hub.attachToAdjacentMyo(); //buggy, not usable
			errorMsg = "Cannot connect, please specify MAC address of Myo.";
		}
	}

	finished = true;
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
@Override
public boolean connect() throws SSJFatalException
{
	myoInitialized = false;
	hub = Hub.getInstance();
       listener = new MyoListener();

	// Myo hub must be initialized in the main ui thread
	Handler handler = new Handler(Looper.getMainLooper());
	MyoConnThread connThread = new MyoConnThread();
	handler.postDelayed(connThread, 1);

	// Wait until myo is connected
	long time = SystemClock.elapsedRealtime();
	while (hub.getConnectedDevices().isEmpty() && SystemClock.elapsedRealtime() - time < _frame.options.waitSensorConnect.get() * 1000 && !_terminate)
	{
		try {
			Thread.sleep(Cons.SLEEP_IN_LOOP);
		} catch (InterruptedException e) {}
	}

	if(connThread.errorMsg != null && !connThread.errorMsg.isEmpty())
	{
		throw new SSJFatalException(connThread.errorMsg);
	}

	if(hub.getConnectedDevices().isEmpty())
	{
		hub.shutdown();

		Log.e("device not found");
		return false;
	}

       myo = hub.getConnectedDevices().get(0);

       //configure myo
       config = new Configuration(hub, listener, options.emg.get(), options.imu.get(), options.gestures.get());
       config.apply(myo.getMacAddress());

	myo.unlock(com.thalmic.myo.Myo.UnlockType.HOLD);

	Log.i("Myo successfully connected: " + myo.getMacAddress());
	return true;
}
 

import com.thalmic.myo.Hub; //导入依赖的package包/类
public Vibrate2Command(Hub hub) {
    super(hub);
}